/* * Copyright 2006 Amazon Technologies, Inc. or its affiliates. * Amazon, Amazon.com and Carbonado are trademarks or registered trademarks * of Amazon Technologies, Inc. or its affiliates. All rights reserved. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package com.amazon.carbonado; import java.io.IOException; import com.amazon.carbonado.filter.Filter; import com.amazon.carbonado.filter.FilterValues; /** * Supports complex retrieval and deletion of {@link Storable} objects. A Query * is defined by {@link Storage#query}, and it merely represents an action. It * does not contain any data, and it is immutable. Query objects are usually * compiled and cached, and the same instance can be re-used for future * queries. * *
Query instances are thread-safe and immutable. All of the apparent
* mutators (with, et al) do not modify the Query, but instead return a new
* Query with the requested modification.
*
* @author Brian S O'Neill
*/
public interface Query {
/**
* Returns the specific type of Storable managed by this object.
*/
Class getStorableType();
/**
* Returns the query's filter.
*/
Filter getFilter();
/**
* Returns the query's filter values, which is null if filter has no
* parameters.
*/
FilterValues getFilterValues();
/**
* Returns the amount of blank parameters that need to be filled in. If
* zero, then this query is ready to be used.
*/
int getBlankParameterCount();
/**
* Returns a copy of this Query with the next blank parameter filled in.
*
* @param value parameter value to fill in
* @throws IllegalStateException if no blank parameters
* @throws IllegalArgumentException if type doesn't match
*/
Query with(int value);
/**
* Returns a copy of this Query with the next blank parameter filled in.
*
* @param value parameter value to fill in
* @throws IllegalStateException if no blank parameters
* @throws IllegalArgumentException if type doesn't match
*/
Query with(long value);
/**
* Returns a copy of this Query with the next blank parameter filled in.
*
* @param value parameter value to fill in
* @throws IllegalStateException if no blank parameters
* @throws IllegalArgumentException if type doesn't match
*/
Query with(float value);
/**
* Returns a copy of this Query with the next blank parameter filled in.
*
* @param value parameter value to fill in
* @throws IllegalStateException if no blank parameters
* @throws IllegalArgumentException if type doesn't match
*/
Query with(double value);
/**
* Returns a copy of this Query with the next blank parameter filled in.
*
* @param value parameter value to fill in
* @throws IllegalStateException if no blank parameters
* @throws IllegalArgumentException if type doesn't match
*/
Query with(boolean value);
/**
* Returns a copy of this Query with the next blank parameter filled in.
*
* @param value parameter value to fill in
* @throws IllegalStateException if no blank parameters
* @throws IllegalArgumentException if type doesn't match
*/
Query with(char value);
/**
* Returns a copy of this Query with the next blank parameter filled in.
*
* @param value parameter value to fill in
* @throws IllegalStateException if no blank parameters
* @throws IllegalArgumentException if type doesn't match
*/
Query with(byte value);
/**
* Returns a copy of this Query with the next blank parameter filled in.
*
* @param value parameter value to fill in
* @throws IllegalStateException if no blank parameters
* @throws IllegalArgumentException if type doesn't match
*/
Query with(short value);
/**
* Returns a copy of this Query with the next blank parameter filled in.
*
* @param value parameter value to fill in
* @throws IllegalStateException if no blank parameters
* @throws IllegalArgumentException if type doesn't match
*/
Query with(Object value);
/**
* Returns a copy of this Query with the next blank parameters filled in.
*
* @param values parameter values to fill in; if null or empty, this
* Query instance is returned
* @throws IllegalStateException if no blank parameters or if too many
* parameter values supplied
* @throws IllegalArgumentException if any type doesn't match
*/
Query withValues(Object... values);
/**
* Returns a new query which has another {@link Storage#query(String)
* filter} logically "and"ed to this, potentially reducing the amount of
* results.
*
* @param filter query filter expression
* @throws FetchException if storage layer throws an exception
* @throws IllegalStateException if any blank parameters in this query, or
* if this query is already guaranteed to fetch nothing
* @throws IllegalArgumentException if filter is null
* @throws MalformedFilterException if expression is malformed
* @throws UnsupportedOperationException if given filter is unsupported by repository
*/
Query and(String filter) throws FetchException;
/**
* Returns a new query which has another {@link Storage#query(String)
* filter} logically "and"ed to this, potentially reducing the amount of
* results.
*
* @param filter query filter
* @throws FetchException if storage layer throws an exception
* @throws IllegalStateException if any blank parameters in this query, or
* if this query is already guaranteed to fetch nothing
* @throws IllegalArgumentException if filter is null
* @throws UnsupportedOperationException if given filter is unsupported by repository
*/
Query and(Filter filter) throws FetchException;
/**
* Returns a new query which has another {@link Storage#query(String)
* filter} logically "or"ed to this, potentially increasing the amount of
* results.
*
* @param filter query filter expression
* @throws FetchException if storage layer throws an exception
* @throws IllegalStateException if any blank parameters in this query, or
* if this query is already guaranteed to fetch everything
* @throws IllegalArgumentException if filter is null
* @throws MalformedFilterException if expression is malformed
* @throws UnsupportedOperationException if given filter is unsupported by repository
*/
Query or(String filter) throws FetchException;
/**
* Returns a new query which has another {@link Storage#query(String)
* filter} logically "or"ed to this, potentially increasing the amount of
* results.
*
* @param filter query filter
* @throws FetchException if storage layer throws an exception
* @throws IllegalStateException if any blank parameters in this query, or
* if this query is already guaranteed to fetch everything
* @throws IllegalArgumentException if filter is null
* @throws UnsupportedOperationException if given filter is unsupported by repository
*/
Query or(Filter filter) throws FetchException;
/**
* Returns a new query which produces all the results not supplied in this
* query. Any filled in parameters in this query are copied into the new
* one.
*
* @throws FetchException if storage layer throws an exception
* @throws UnsupportedOperationException if new query is unsupported by repository
*/
Query not() throws FetchException;
/**
* Returns a copy of this query ordered by a specific property value. The
* property name may be prefixed with '+' or '-' to indicate ascending or
* descending order. If the prefix is omitted, ascending order is assumed.
*
*
Note: Specification of ordering properties is not cumulative. Calling
* this method will first remove any previous ordering properties.
*
* @param property name of property to order by
* @throws FetchException if storage layer throws an exception
* @throws IllegalArgumentException if property is null or is not a member
* of type S
* @throws UnsupportedOperationException if given ordering, combined with
* query filter, is unsupported by repository
*/
Query orderBy(String property) throws FetchException;
/**
* Returns a copy of this query ordered by specific property values. The
* property names may be prefixed with '+' or '-' to indicate ascending or
* descending order. If the prefix is omitted, ascending order is assumed.
*
*
Note: Specification of ordering properties is not cumulative. Calling
* this method will first remove any previous ordering properties.
*
* @param properties names of properties to order by
* @throws FetchException if storage layer throws an exception
* @throws IllegalArgumentException if any property is null or is not a
* member of type S
* @throws UnsupportedOperationException if given ordering, combined with
* query filter, is unsupported by repository
*/
Query orderBy(String... properties) throws FetchException;
/**
* Fetches results for this query. If any updates or deletes might be
* performed on the results, consider enclosing the fetch in a
* transaction. This allows the isolation level and "for update" mode to be
* adjusted. Some repositories might otherwise deadlock.
*
* @return fetch results
* @throws IllegalStateException if any blank parameters in this query
* @throws FetchException if storage layer throws an exception
* @see Repository#enterTransaction(IsolationLevel)
*/
Cursor fetch() throws FetchException;
/**
* Fetches results for this query after a given starting point, which is
* useful for re-opening a cursor. This is only effective when query has
* been given an explicit {@link #orderBy ordering}. If not a total
* ordering, then returned cursor may start at an earlier position.
*
*
Note: This method can be very expensive to call repeatedly, if the
* query needs to perform a sort operation. Ideally, the query ordering
* should match the natural ordering of an index or key.
*
* @param start storable to attempt to start after; if null, fetch all results
* @return fetch results
* @throws IllegalStateException if any blank parameters in this query
* @throws FetchException if storage layer throws an exception
* @see Repository#enterTransaction(IsolationLevel)
*/
Cursor fetchAfter(S start) throws FetchException;
/**
* Attempts to load exactly one matching object. If the number of matching
* records is zero or exceeds one, then an exception is thrown instead.
*
* @return a single fetched object
* @throws IllegalStateException if any blank parameters in this query
* @throws FetchNoneException if no matching record found
* @throws FetchMultipleException if more than one matching record found
* @throws FetchException if storage layer throws an exception
*/
S loadOne() throws FetchException;
/**
* May return null if nothing found. Throws exception if record count is
* more than one.
*
* @return null or a single fetched object
* @throws IllegalStateException if any blank parameters in this query
* @throws FetchMultipleException if more than one matching record found
* @throws FetchException if storage layer throws an exception
*/
S tryLoadOne() throws FetchException;
/**
* Deletes one matching object. If the number of matching records is zero or
* exceeds one, then no delete occurs, and an exception is thrown instead.
*
* @throws IllegalStateException if any blank parameters in this query
* @throws PersistNoneException if no matching record found
* @throws PersistMultipleException if more than one record matches
* @throws PersistException if storage layer throws an exception
*/
void deleteOne() throws PersistException;
/**
* Deletes zero or one matching objects. If the number of matching records
* exceeds one, then no delete occurs, and an exception is thrown instead.
*
* @return true if record existed and was deleted, or false if no match
* @throws IllegalStateException if any blank parameters in this query
* @throws PersistMultipleException if more than one record matches
* @throws PersistException if storage layer throws an exception
*/
boolean tryDeleteOne() throws PersistException;
/**
* Deletes zero or more matching objects. There is no guarantee that
* deleteAll is an atomic operation. If atomic behavior is desired, wrap
* the call in a transaction scope.
*
* @throws IllegalStateException if any blank parameters in this query
* @throws PersistException if storage layer throws an exception
*/
void deleteAll() throws PersistException;
/**
* Returns a count of all results matched by this query. Even though no
* results are explicitly fetched, this method may still be expensive to
* call. The actual performance will vary by repository and available indexes.
*
* @return count of matches
* @throws IllegalStateException if any blank parameters in this query
* @throws FetchException if storage layer throws an exception
*/
long count() throws FetchException;
/**
* Print the native query to standard out, which is useful for performance
* analysis. Not all repositories have a native query format. An example
* native format is SQL.
*
* @return false if not implemented
*/
boolean printNative();
/**
* Prints the native query to any appendable, which is useful for
* performance analysis. Not all repositories have a native query
* format. An example native format is SQL.
*
* @param app append results here
* @return false if not implemented
*/
boolean printNative(Appendable app) throws IOException;
/**
* Prints the native query to any appendable, which is useful for
* performance analysis. Not all repositories have a native query
* format. An example native format is SQL.
*
* @param app append results here
* @param indentLevel amount to indent text, zero for none
* @return false if not implemented
*/
boolean printNative(Appendable app, int indentLevel) throws IOException;
/**
* Prints the query excecution plan to standard out, which is useful for
* performance analysis. There is no standard format for query plans, nor
* is it a requirement that this method be implemented.
*
* @return false if not implemented
*/
boolean printPlan();
/**
* Prints the query excecution plan to any appendable, which is useful for
* performance analysis. There is no standard format for query plans, nor
* is it a requirement that this method be implemented.
*
* @param app append results here
* @return false if not implemented
*/
boolean printPlan(Appendable app) throws IOException;
/**
* Prints the query excecution plan to any appendable, which is useful for
* performance analysis. There is no standard format for query plans, nor
* is it a requirement that this method be implemented.
*
* @param app append results here
* @param indentLevel amount to indent text, zero for none
* @return false if not implemented
*/
boolean printPlan(Appendable app, int indentLevel) throws IOException;
int hashCode();
boolean equals(Object obj);
/**
* Returns a description of the query filter and any other arguments.
*/
String toString();
}