public class ServerClient extends java.lang.Object implements IDatabaseCommands
Modifier and Type | Class and Description |
---|---|
class |
ServerClient.HandleReplicationStatusChangesCallback |
Modifier and Type | Field and Description |
---|---|
protected HttpJsonRequestFactory |
jsonRequestFactory |
protected java.util.Map<java.lang.String,java.lang.String> |
operationsHeaders |
protected int |
readStripingBase |
protected int |
requestCount |
protected java.lang.String |
url |
Constructor and Description |
---|
ServerClient(java.lang.String url,
DocumentConvention convention,
OperationCredentials credentials,
Function1<java.lang.String,IDocumentStoreReplicationInformer> replicationInformerGetter,
java.lang.String databaseName,
HttpJsonRequestFactory httpJsonRequestFactory,
java.util.UUID sessionId,
IDocumentConflictListener[] conflictListeners) |
Modifier and Type | Method and Description |
---|---|
void |
addFailoverStatusChanged(EventHandler<ReplicationInformer.FailoverStatusChangedEventArgs> event) |
BatchResult[] |
batch(java.util.List<ICommandData> commandDatas)
Executed the specified commands as a single batch
|
HttpJsonRequest |
createReplicationAwareRequest(java.lang.String currentServerUrl,
java.lang.String requestUrl,
HttpMethods method) |
HttpJsonRequest |
createReplicationAwareRequest(java.lang.String currentServerUrl,
java.lang.String requestUrl,
HttpMethods method,
boolean disableRequestCompression) |
HttpJsonRequest |
createRequest(HttpMethods method,
java.lang.String requestUrl) |
HttpJsonRequest |
createRequest(HttpMethods method,
java.lang.String requestUrl,
boolean disableRequestCompression,
boolean disableAuthentication,
java.lang.Long timeout) |
void |
delete(java.lang.String key,
Etag etag)
Deletes the document with the specified key
|
void |
deleteAttachment(java.lang.String key,
Etag etag)
Deprecated.
|
Operation |
deleteByIndex(java.lang.String indexName,
IndexQuery queryToDelete)
Perform a set based deletes using the specified index, not allowing the operation
if the index is stale
|
Operation |
deleteByIndex(java.lang.String indexName,
IndexQuery queryToDelete,
BulkOperationOptions options)
Perform a set based deletes using the specified index.
|
void |
deleteIndex(java.lang.String name)
Delete index
|
void |
deleteTransformer(java.lang.String name)
Deletes the specified transformer
|
protected BatchResult[] |
directBatch(java.util.List<ICommandData> commandDatas,
OperationMetadata operationMetadata) |
protected void |
directDelete(OperationMetadata operationMetadata,
java.lang.String key,
Etag etag) |
protected void |
directDeleteAttachment(java.lang.String key,
Etag etag,
OperationMetadata operationMetadata)
Deprecated.
|
protected Operation |
directDeleteByIndex(OperationMetadata operationMetadata,
java.lang.String indexName,
IndexQuery queryToDelete,
BulkOperationOptions options) |
protected void |
directDeleteIndex(java.lang.String name,
OperationMetadata operationMetadata) |
protected void |
directDeleteTransformer(java.lang.String name,
OperationMetadata operationMetadata) |
JsonDocument |
directGet(OperationMetadata operationMetadata,
java.lang.String key) |
JsonDocument |
directGet(OperationMetadata operationMetadata,
java.lang.String key,
java.lang.String transform)
Perform a direct get for a document with the specified key on the specified server URL.
|
protected MultiLoadResult |
directGet(java.lang.String[] ids,
OperationMetadata operationMetadata,
java.lang.String[] includes,
java.lang.String transformer,
java.util.Map<java.lang.String,RavenJToken> transformerParameters,
boolean metadataOnly) |
protected Attachment |
directGetAttachment(HttpMethods method,
java.lang.String key,
OperationMetadata operationMetadata)
Deprecated.
|
protected java.util.List<Attachment> |
directGetAttachmentHeadersStartingWith(HttpMethods method,
java.lang.String idPrefix,
int start,
int pageSize,
OperationMetadata operationMetadata)
Deprecated.
|
protected AttachmentInformation[] |
directGetAttachments(int start,
Etag startEtag,
int pageSize,
OperationMetadata operationMetadata)
Deprecated.
|
protected FacetResults |
directGetFacets(OperationMetadata operationMetadata,
java.lang.String index,
IndexQuery query,
java.lang.String facetSetupDoc,
int start,
java.lang.Integer pageSize) |
protected FacetResults |
directGetFacets(OperationMetadata operationMetadata,
java.lang.String index,
IndexQuery query,
java.lang.String facetsJson,
int start,
java.lang.Integer pageSize,
HttpMethods method) |
protected IndexDefinition |
directGetIndex(java.lang.String indexName,
OperationMetadata operationMetadata) |
protected java.util.Collection<IndexDefinition> |
directGetIndexes(int start,
int pageSize,
OperationMetadata operationMetadata) |
protected java.util.Collection<java.lang.String> |
directGetIndexNames(int start,
int pageSize,
OperationMetadata operationMetadata) |
protected FacetResults[] |
directGetMultiFacets(OperationMetadata operationMetadata,
FacetQuery[] facetedQueries) |
ReplicationDocument |
directGetReplicationDestinations(OperationMetadata operationMetadata) |
protected java.util.List<java.lang.String> |
directGetTerms(OperationMetadata operationMetadata,
java.lang.String index,
java.lang.String field,
java.lang.String fromValue,
int pageSize) |
protected TransformerDefinition |
directGetTransformer(java.lang.String transformerName,
OperationMetadata operationMetadata) |
protected java.util.List<TransformerDefinition> |
directGetTransformers(OperationMetadata operationMetadata,
int start,
int pageSize) |
protected JsonDocumentMetadata |
directHead(OperationMetadata operationMetadata,
java.lang.String key) |
protected java.lang.Boolean |
directIndexHasChanged(java.lang.String name,
IndexDefinition definition,
OperationMetadata operationMetadata) |
protected GetResponse[] |
directMultiGet(OperationMetadata operationMetadata,
GetRequest[] requests) |
protected java.lang.Long |
directNextIdentityFor(java.lang.String name,
OperationMetadata operationMetadata) |
protected PutResult |
directPut(RavenJObject metadata,
java.lang.String key,
Etag etag,
RavenJObject document,
OperationMetadata operationMetadata) |
protected void |
directPutAttachment(java.lang.String key,
RavenJObject metadata,
Etag etag,
java.io.InputStream data,
OperationMetadata operationMetadata)
Deprecated.
|
java.lang.String |
directPutIndex(java.lang.String name,
IndexDefinition definition,
boolean overwrite,
OperationMetadata operationMetadata) |
java.lang.String |
directPutTransformer(java.lang.String name,
OperationMetadata operationMetadata,
TransformerDefinition definition) |
protected QueryResult |
directQuery(HttpMethods method,
java.lang.String index,
IndexQuery query,
OperationMetadata operationMetadata,
java.lang.String[] includes,
boolean metadataOnly,
boolean includeEntries) |
protected void |
directResetIndex(java.lang.String name,
OperationMetadata operationMetadata) |
protected java.util.List<JsonDocument> |
directStartsWith(OperationMetadata operationMetadata,
java.lang.String keyPrefix,
java.lang.String matches,
int start,
int pageSize,
boolean metadataOnly,
java.lang.String exclude,
RavenPagingInformation pagingInformation,
java.lang.String transformer,
java.util.Map<java.lang.String,RavenJToken> transformerParameters,
java.lang.String skipAfter) |
protected SuggestionQueryResult |
directSuggest(java.lang.String index,
SuggestionQuery suggestionQuery,
OperationMetadata operationMetadata) |
protected void |
directUpdateAttachmentMetadata(java.lang.String key,
RavenJObject metadata,
Etag etag,
OperationMetadata operationMetadata)
Deprecated.
|
protected Operation |
directUpdateByIndexImpl(OperationMetadata operationMetadata,
java.lang.String indexName,
IndexQuery queryToUpdate,
BulkOperationOptions options,
java.lang.String requestData,
HttpMethods method) |
java.lang.AutoCloseable |
disableAllCaching()
Disable all caching within the given scope
|
RavenJToken |
executeGetRequest(java.lang.String requestUrl) |
<S> S |
executeWithReplication(HttpMethods method,
Function1<OperationMetadata,S> operation) |
protected ConcurrencyException |
fetchConcurrencyException(HttpOperationException e) |
java.lang.AutoCloseable |
forceReadFromMaster()
Force the database commands to read directly from the master, unless there has been a failover.
|
IDatabaseCommands |
forDatabase(java.lang.String database)
Create a new instance of
IDatabaseCommands that will interacts with the specified database |
IDatabaseCommands |
forSystemDatabase()
Creates a new instance of
IDatabaseCommands that will interacts with the default database. |
JsonDocument |
get(java.lang.String key)
Retrieves the document for the specified key
|
MultiLoadResult |
get(java.lang.String[] ids,
java.lang.String[] includes)
Gets the results for the specified ids.
|
MultiLoadResult |
get(java.lang.String[] ids,
java.lang.String[] includes,
java.lang.String transformer)
Gets the results for the specified ids.
|
MultiLoadResult |
get(java.lang.String[] ids,
java.lang.String[] includes,
java.lang.String transformer,
java.util.Map<java.lang.String,RavenJToken> transformerParameters)
Gets the results for the specified ids.
|
MultiLoadResult |
get(java.lang.String[] ids,
java.lang.String[] includes,
java.lang.String transformer,
java.util.Map<java.lang.String,RavenJToken> transformerParameters,
boolean metadataOnly) |
IAdminDatabaseCommands |
getAdmin() |
Attachment |
getAttachment(java.lang.String key)
Deprecated.
|
java.util.List<Attachment> |
getAttachmentHeadersStartingWith(java.lang.String idPrefix,
int start,
int pageSize)
Deprecated.
|
AttachmentInformation[] |
getAttachments(int start,
Etag startEtag,
int pageSize)
Deprecated.
|
BuildNumber |
getBuildNumber() |
ILowLevelBulkInsertOperation |
getBulkInsertOperation(BulkInsertOptions options,
IDatabaseChanges changes) |
java.util.List<JsonDocument> |
getDocuments(int start,
int pageSize)
Get documents from server
|
java.util.List<JsonDocument> |
getDocuments(int start,
int pageSize,
boolean metadataOnly)
Get documents from server
|
FacetResults |
getFacets(java.lang.String index,
IndexQuery query,
java.util.List<Facet> facets)
Using the given Index, calculate the facets as per the specified doc with the given start and pageSize
|
FacetResults |
getFacets(java.lang.String index,
IndexQuery query,
java.util.List<Facet> facets,
int start)
Using the given Index, calculate the facets as per the specified doc with the given start and pageSize
|
FacetResults |
getFacets(java.lang.String index,
IndexQuery query,
java.util.List<Facet> facets,
int start,
java.lang.Integer pageSize)
Using the given Index, calculate the facets as per the specified doc with the given start and pageSize
|
FacetResults |
getFacets(java.lang.String index,
IndexQuery query,
java.lang.String facetSetupDoc)
Using the given Index, calculate the facets as per the specified doc
|
FacetResults |
getFacets(java.lang.String index,
IndexQuery query,
java.lang.String facetSetupDoc,
int start)
Using the given Index, calculate the facets as per the specified doc with the given start
|
FacetResults |
getFacets(java.lang.String index,
IndexQuery query,
java.lang.String facetSetupDoc,
int start,
java.lang.Integer pageSize)
Using the given Index, calculate the facets as per the specified doc with the given start and pageSize
|
IGlobalAdminDatabaseCommands |
getGlobalAdmin()
Admin operations performed against system database, like create/delete database
|
IndexDefinition |
getIndex(java.lang.String name)
Gets the index definition for the specified name
|
java.util.Collection<IndexDefinition> |
getIndexes(int start,
int pageSize)
Returns
IndexDefinition s |
IndexMergeResults |
getIndexMergeSuggestions() |
java.util.Collection<java.lang.String> |
getIndexNames(int start,
int pageSize)
Gets the index names from the server
|
HttpJsonRequestFactory |
getJsonRequestFactory() |
FacetResults[] |
getMultiFacets(FacetQuery[] facetedQueries)
Sends a multiple faceted queries in a single request and calculates the facet results for each of them
|
java.util.Map<java.lang.String,java.lang.String> |
getOperationsHeaders() |
RavenJToken |
getOperationStatus(long id) |
OperationCredentials |
getPrimaryCredentials() |
ProfilingInformation |
getProfilingInformation()
The profiling information
|
IDocumentStoreReplicationInformer |
getReplicationInformer() |
java.lang.String |
getSingleAuthToken() |
DatabaseStatistics |
getStatistics()
Returns server statistics
|
java.util.List<java.lang.String> |
getTerms(java.lang.String index,
java.lang.String field,
java.lang.String fromValue,
int pageSize)
Get the all terms stored in the index for the specified field
You can page through the results by use fromValue parameter as the
starting point for the next query
|
TransformerDefinition |
getTransformer(java.lang.String name)
Gets the transformer definition for the specified name
|
java.util.List<TransformerDefinition> |
getTransformers(int start,
int pageSize)
Gets the transformers from the server
|
java.lang.String |
getUrl() |
protected void |
handleReplicationStatusChanges(java.util.Map<java.lang.String,java.lang.String> headers,
java.lang.String primaryUrl,
java.lang.String currentUrl) |
JsonDocumentMetadata |
head(java.lang.String key)
Checks if the document exists for the specified key
|
Attachment |
headAttachment(java.lang.String key)
Deprecated.
|
boolean |
indexHasChanged(java.lang.String name,
IndexDefinition definition)
Checks if passed index definition matches version stored on server.
|
boolean |
isExpect100Continue()
Is expect 100 continue?
|
boolean |
isInFailoverMode() |
MultiLoadResult |
moreLikeThis(MoreLikeThisQuery query)
Return a list of documents that based on the MoreLikeThisQuery.
|
GetResponse[] |
multiGet(GetRequest[] requests)
Perform a single POST request containing multiple nested GET requests
|
java.lang.Long |
nextIdentityFor(java.lang.String name)
Generate the next identity value from the server
|
RavenJObject |
patch(java.lang.String key,
PatchRequest[] patches)
Sends a patch request for a specific document, ignoring the document's Etag
|
RavenJObject |
patch(java.lang.String key,
PatchRequest[] patches,
boolean ignoreMissing)
Sends a patch request for a specific document, ignoring the document's Etag
|
RavenJObject |
patch(java.lang.String key,
PatchRequest[] patches,
Etag etag)
Sends a patch request for a specific document
|
RavenJObject |
patch(java.lang.String key,
PatchRequest[] patchesToExisting,
PatchRequest[] patchesToDefault,
RavenJObject defaultMetadata)
Sends a patch request for a specific document which may or may not currently exist
|
RavenJObject |
patch(java.lang.String key,
ScriptedPatchRequest patch)
Sends a patch request for a specific document, ignoring the document's Etag
|
RavenJObject |
patch(java.lang.String key,
ScriptedPatchRequest patch,
boolean ignoreMissing)
Sends a patch request for a specific document, ignoring the document's Etag
|
RavenJObject |
patch(java.lang.String key,
ScriptedPatchRequest patch,
Etag etag)
Sends a patch request for a specific document, ignoring the document's Etag
|
RavenJObject |
patch(java.lang.String key,
ScriptedPatchRequest patchExisting,
ScriptedPatchRequest patchDefault,
RavenJObject defaultMetadata)
Sends a patch request for a specific document which may or may not currently exist
|
PutResult |
put(java.lang.String key,
Etag etag,
RavenJObject document,
RavenJObject metadata)
Puts the document in the database with the specified key
|
void |
putAttachment(java.lang.String key,
Etag etag,
java.io.InputStream data,
RavenJObject metadata)
Deprecated.
|
java.lang.String |
putIndex(java.lang.String name,
IndexDefinition definition)
Puts index with given definition
|
java.lang.String |
putIndex(java.lang.String name,
IndexDefinition definition,
boolean overwrite)
Puts the index.
|
java.lang.String |
putIndex(java.lang.String name,
IndexDefinitionBuilder indexDef)
Creates an index with the specified name, based on an index definition
|
java.lang.String |
putIndex(java.lang.String name,
IndexDefinitionBuilder indexDef,
boolean overwrite)
Creates an index with the specified name, based on an index definition
|
java.lang.String |
putTransformer(java.lang.String name,
TransformerDefinition indexDef)
Creates a transformer with the specified name, based on an transformer definition
|
QueryResult |
query(java.lang.String index,
IndexQuery query)
Performs index query
|
QueryResult |
query(java.lang.String index,
IndexQuery query,
java.lang.String[] includes)
Performs index query
|
QueryResult |
query(java.lang.String index,
IndexQuery query,
java.lang.String[] includes,
boolean metadataOnly)
Performs index query
|
QueryResult |
query(java.lang.String index,
IndexQuery query,
java.lang.String[] includes,
boolean metadataOnly,
boolean indexEntriesOnly)
Performs index query
|
void |
removeFailoverStatusChanged(EventHandler<ReplicationInformer.FailoverStatusChangedEventArgs> event) |
void |
resetIndex(java.lang.String name)
Resets the specified index
|
long |
seedIdentityFor(java.lang.String name,
long value)
Seeds the next identity value on the server
|
void |
setExpect100Continue(boolean expect100Continue) |
void |
setOperationsHeaders(java.util.Map<java.lang.String,java.lang.String> operationsHeaders)
Sets the operations headers
|
java.util.List<JsonDocument> |
startsWith(java.lang.String keyPrefix,
java.lang.String matches,
int start,
int pageSize)
Retrieves documents for the specified key prefix
|
java.util.List<JsonDocument> |
startsWith(java.lang.String keyPrefix,
java.lang.String matches,
int start,
int pageSize,
boolean metadataOnly)
Retrieves documents for the specified key prefix
|
java.util.List<JsonDocument> |
startsWith(java.lang.String keyPrefix,
java.lang.String matches,
int start,
int pageSize,
boolean metadataOnly,
java.lang.String exclude)
Retrieves documents for the specified key prefix
|
java.util.List<JsonDocument> |
startsWith(java.lang.String keyPrefix,
java.lang.String matches,
int start,
int pageSize,
boolean metadataOnly,
java.lang.String exclude,
RavenPagingInformation pagingInformation)
Retrieves documents for the specified key prefix
|
java.util.List<JsonDocument> |
startsWith(java.lang.String keyPrefix,
java.lang.String matches,
int start,
int pageSize,
boolean metadataOnly,
java.lang.String exclude,
RavenPagingInformation pagingInformation,
java.lang.String transformer,
java.util.Map<java.lang.String,RavenJToken> transformerParameters) |
java.util.List<JsonDocument> |
startsWith(java.lang.String keyPrefix,
java.lang.String matches,
int start,
int pageSize,
boolean metadataOnly,
java.lang.String exclude,
RavenPagingInformation pagingInformation,
java.lang.String transformer,
java.util.Map<java.lang.String,RavenJToken> transformerParameters,
java.lang.String skipAfter) |
RavenJObjectIterator |
streamDocs()
Streams the documents by etag OR starts with the prefix and match the matches
Will return *all* results, regardless of the number of items that might be returned.
|
RavenJObjectIterator |
streamDocs(Etag fromEtag)
Streams the documents by etag OR starts with the prefix and match the matches
Will return *all* results, regardless of the number of items that might be returned.
|
RavenJObjectIterator |
streamDocs(Etag fromEtag,
java.lang.String startsWith)
Streams the documents by etag OR starts with the prefix and match the matches
Will return *all* results, regardless of the number of items that might be returned.
|
RavenJObjectIterator |
streamDocs(Etag fromEtag,
java.lang.String startsWith,
java.lang.String matches)
Streams the documents by etag OR starts with the prefix and match the matches
Will return *all* results, regardless of the number of items that might be returned.
|
RavenJObjectIterator |
streamDocs(Etag fromEtag,
java.lang.String startsWith,
java.lang.String matches,
int start)
Streams the documents by etag OR starts with the prefix and match the matches
Will return *all* results, regardless of the number of items that might be returned.
|
RavenJObjectIterator |
streamDocs(Etag fromEtag,
java.lang.String startsWith,
java.lang.String matches,
int start,
int pageSize)
Streams the documents by etag OR starts with the prefix and match the matches
Will return *all* results, regardless of the number of items that might be returned.
|
RavenJObjectIterator |
streamDocs(Etag fromEtag,
java.lang.String startsWith,
java.lang.String matches,
int start,
int pageSize,
java.lang.String exclude)
Streams the documents by etag OR starts with the prefix and match the matches
Will return *all* results, regardless of the number of items that might be returned.
|
RavenJObjectIterator |
streamDocs(Etag fromEtag,
java.lang.String startsWith,
java.lang.String matches,
int start,
int pageSize,
java.lang.String exclude,
RavenPagingInformation pagingInformation)
Streams the documents by etag OR starts with the prefix and match the matches
Will return *all* results, regardless of the number of items that might be returned.
|
RavenJObjectIterator |
streamDocs(Etag fromEtag,
java.lang.String startsWith,
java.lang.String matches,
int start,
int pageSize,
java.lang.String exclude,
RavenPagingInformation pagingInformation,
java.lang.String skipAfter)
Streams the documents by etag OR starts with the prefix and match the matches
Will return *all* results, regardless of the number of items that might be returned.
|
RavenJObjectIterator |
streamQuery(java.lang.String index,
IndexQuery query,
Reference<QueryHeaderInformation> queryHeaderInfo)
Queries the specified index in the Raven flavored Lucene query syntax.
|
SuggestionQueryResult |
suggest(java.lang.String index,
SuggestionQuery suggestionQuery)
Returns a list of suggestions based on the specified suggestion query
|
java.lang.Boolean |
tryResolveConflictByUsingRegisteredListeners(java.lang.String key,
Etag etag,
java.lang.String[] conflictedIds,
OperationMetadata operationMetadata)
Tries to resolve conflict using registered listeners
|
void |
updateAttachmentMetadata(java.lang.String key,
Etag etag,
RavenJObject metadata)
Deprecated.
|
Operation |
updateByIndex(java.lang.String indexName,
IndexQuery queryToUpdate,
PatchRequest[] patchRequests)
Perform a set based update using the specified index, not allowing the operation
if the index is stale
|
Operation |
updateByIndex(java.lang.String indexName,
IndexQuery queryToUpdate,
PatchRequest[] patchRequests,
BulkOperationOptions options)
Perform a set based update using the specified index.
|
Operation |
updateByIndex(java.lang.String indexName,
IndexQuery queryToUpdate,
ScriptedPatchRequest patch)
Perform a set based update using the specified index, not allowing the operation
if the index is stale
|
Operation |
updateByIndex(java.lang.String indexName,
IndexQuery queryToUpdate,
ScriptedPatchRequest patch,
BulkOperationOptions options)
Perform a set based update using the specified index.
|
java.lang.String |
urlFor(java.lang.String documentKey)
Get the full URL for the given document key
|
protected java.lang.String url
protected java.util.Map<java.lang.String,java.lang.String> operationsHeaders
protected final HttpJsonRequestFactory jsonRequestFactory
protected int requestCount
protected int readStripingBase
public ServerClient(java.lang.String url, DocumentConvention convention, OperationCredentials credentials, Function1<java.lang.String,IDocumentStoreReplicationInformer> replicationInformerGetter, java.lang.String databaseName, HttpJsonRequestFactory httpJsonRequestFactory, java.util.UUID sessionId, IDocumentConflictListener[] conflictListeners)
public void addFailoverStatusChanged(EventHandler<ReplicationInformer.FailoverStatusChangedEventArgs> event)
public void removeFailoverStatusChanged(EventHandler<ReplicationInformer.FailoverStatusChangedEventArgs> event)
public HttpJsonRequestFactory getJsonRequestFactory()
public IndexMergeResults getIndexMergeSuggestions()
getIndexMergeSuggestions
in interface IDatabaseCommands
public BuildNumber getBuildNumber()
public java.util.Collection<java.lang.String> getIndexNames(int start, int pageSize)
IDatabaseCommands
getIndexNames
in interface IDatabaseCommands
protected java.util.Collection<java.lang.String> directGetIndexNames(int start, int pageSize, OperationMetadata operationMetadata)
public java.util.Collection<IndexDefinition> getIndexes(int start, int pageSize)
IDatabaseCommands
IndexDefinition
sgetIndexes
in interface IDatabaseCommands
protected java.util.Collection<IndexDefinition> directGetIndexes(int start, int pageSize, OperationMetadata operationMetadata)
public java.util.List<TransformerDefinition> getTransformers(int start, int pageSize)
IDatabaseCommands
getTransformers
in interface IDatabaseCommands
protected java.util.List<TransformerDefinition> directGetTransformers(OperationMetadata operationMetadata, int start, int pageSize)
public void resetIndex(java.lang.String name)
IDatabaseCommands
resetIndex
in interface IDatabaseCommands
protected void directResetIndex(java.lang.String name, OperationMetadata operationMetadata)
public boolean indexHasChanged(java.lang.String name, IndexDefinition definition)
IDatabaseCommands
indexHasChanged
in interface IDatabaseCommands
protected java.lang.Boolean directIndexHasChanged(java.lang.String name, IndexDefinition definition, OperationMetadata operationMetadata)
public java.lang.String putIndex(java.lang.String name, IndexDefinition definition)
IDatabaseCommands
putIndex
in interface IDatabaseCommands
public java.lang.String putIndex(java.lang.String name, IndexDefinition definition, boolean overwrite)
IDatabaseCommands
putIndex
in interface IDatabaseCommands
public java.lang.String putIndex(java.lang.String name, IndexDefinitionBuilder indexDef)
IDatabaseCommands
putIndex
in interface IDatabaseCommands
public java.lang.String putIndex(java.lang.String name, IndexDefinitionBuilder indexDef, boolean overwrite)
IDatabaseCommands
putIndex
in interface IDatabaseCommands
public java.lang.String directPutIndex(java.lang.String name, IndexDefinition definition, boolean overwrite, OperationMetadata operationMetadata)
public OperationCredentials getPrimaryCredentials()
getPrimaryCredentials
in interface IDatabaseCommands
public IDocumentStoreReplicationInformer getReplicationInformer()
public java.util.Map<java.lang.String,java.lang.String> getOperationsHeaders()
getOperationsHeaders
in interface IDatabaseCommands
public void setOperationsHeaders(java.util.Map<java.lang.String,java.lang.String> operationsHeaders)
IDatabaseCommands
setOperationsHeaders
in interface IDatabaseCommands
operationsHeaders
- the operationsHeaders to setpublic JsonDocument get(java.lang.String key) throws ServerClientException
IDatabaseCommands
get
in interface IDatabaseCommands
key
- The keyServerClientException
public java.util.List<JsonDocument> startsWith(java.lang.String keyPrefix, java.lang.String matches, int start, int pageSize) throws ServerClientException
IDatabaseCommands
startsWith
in interface IDatabaseCommands
ServerClientException
public java.util.List<JsonDocument> startsWith(java.lang.String keyPrefix, java.lang.String matches, int start, int pageSize, boolean metadataOnly) throws ServerClientException
IDatabaseCommands
startsWith
in interface IDatabaseCommands
ServerClientException
public java.util.List<JsonDocument> startsWith(java.lang.String keyPrefix, java.lang.String matches, int start, int pageSize, boolean metadataOnly, java.lang.String exclude) throws ServerClientException
IDatabaseCommands
startsWith
in interface IDatabaseCommands
ServerClientException
public java.util.List<JsonDocument> startsWith(java.lang.String keyPrefix, java.lang.String matches, int start, int pageSize, boolean metadataOnly, java.lang.String exclude, RavenPagingInformation pagingInformation) throws ServerClientException
IDatabaseCommands
startsWith
in interface IDatabaseCommands
ServerClientException
public java.util.List<JsonDocument> startsWith(java.lang.String keyPrefix, java.lang.String matches, int start, int pageSize, boolean metadataOnly, java.lang.String exclude, RavenPagingInformation pagingInformation, java.lang.String transformer, java.util.Map<java.lang.String,RavenJToken> transformerParameters) throws ServerClientException
startsWith
in interface IDatabaseCommands
ServerClientException
public java.util.List<JsonDocument> startsWith(java.lang.String keyPrefix, java.lang.String matches, int start, int pageSize, boolean metadataOnly, java.lang.String exclude, RavenPagingInformation pagingInformation, java.lang.String transformer, java.util.Map<java.lang.String,RavenJToken> transformerParameters, java.lang.String skipAfter) throws ServerClientException
startsWith
in interface IDatabaseCommands
ServerClientException
public RavenJToken executeGetRequest(java.lang.String requestUrl)
public HttpJsonRequest createRequest(HttpMethods method, java.lang.String requestUrl)
public HttpJsonRequest createRequest(HttpMethods method, java.lang.String requestUrl, boolean disableRequestCompression, boolean disableAuthentication, java.lang.Long timeout)
public HttpJsonRequest createReplicationAwareRequest(java.lang.String currentServerUrl, java.lang.String requestUrl, HttpMethods method)
public HttpJsonRequest createReplicationAwareRequest(java.lang.String currentServerUrl, java.lang.String requestUrl, HttpMethods method, boolean disableRequestCompression)
public <S> S executeWithReplication(HttpMethods method, Function1<OperationMetadata,S> operation) throws ServerClientException
ServerClientException
public boolean isInFailoverMode()
public JsonDocument directGet(OperationMetadata operationMetadata, java.lang.String key)
public JsonDocument directGet(OperationMetadata operationMetadata, java.lang.String key, java.lang.String transform) throws ServerClientException
operationMetadata
- key
- transform
- ServerClientException
protected void handleReplicationStatusChanges(java.util.Map<java.lang.String,java.lang.String> headers, java.lang.String primaryUrl, java.lang.String currentUrl)
public java.util.List<JsonDocument> getDocuments(int start, int pageSize)
IDatabaseCommands
getDocuments
in interface IDatabaseCommands
public java.util.List<JsonDocument> getDocuments(int start, int pageSize, boolean metadataOnly)
IDatabaseCommands
getDocuments
in interface IDatabaseCommands
start
- Paging startpageSize
- Size of the page.metadataOnly
- Load just the document metadatapublic PutResult put(java.lang.String key, Etag etag, RavenJObject document, RavenJObject metadata) throws ServerClientException
IDatabaseCommands
put
in interface IDatabaseCommands
key
- The key.etag
- The etag.document
- The document.metadata
- The metadata.ServerClientException
protected java.util.List<JsonDocument> directStartsWith(OperationMetadata operationMetadata, java.lang.String keyPrefix, java.lang.String matches, int start, int pageSize, boolean metadataOnly, java.lang.String exclude, RavenPagingInformation pagingInformation, java.lang.String transformer, java.util.Map<java.lang.String,RavenJToken> transformerParameters, java.lang.String skipAfter) throws ServerClientException
ServerClientException
protected PutResult directPut(RavenJObject metadata, java.lang.String key, Etag etag, RavenJObject document, OperationMetadata operationMetadata) throws ServerClientException
ServerClientException
public void delete(java.lang.String key, Etag etag) throws ServerClientException
IDatabaseCommands
delete
in interface IDatabaseCommands
key
- The key.etag
- The etag.ServerClientException
@Deprecated public void putAttachment(java.lang.String key, Etag etag, java.io.InputStream data, RavenJObject metadata)
IDatabaseCommands
putAttachment
in interface IDatabaseCommands
key
- The key.etag
- The etag.data
- The data.metadata
- The metadata.@Deprecated public void updateAttachmentMetadata(java.lang.String key, Etag etag, RavenJObject metadata)
IDatabaseCommands
updateAttachmentMetadata
in interface IDatabaseCommands
key
- The key.etag
- The etag.metadata
- The metadata.@Deprecated protected void directUpdateAttachmentMetadata(java.lang.String key, RavenJObject metadata, Etag etag, OperationMetadata operationMetadata)
@Deprecated protected void directPutAttachment(java.lang.String key, RavenJObject metadata, Etag etag, java.io.InputStream data, OperationMetadata operationMetadata)
@Deprecated public java.util.List<Attachment> getAttachmentHeadersStartingWith(java.lang.String idPrefix, int start, int pageSize)
IDatabaseCommands
getAttachmentHeadersStartingWith
in interface IDatabaseCommands
@Deprecated protected java.util.List<Attachment> directGetAttachmentHeadersStartingWith(HttpMethods method, java.lang.String idPrefix, int start, int pageSize, OperationMetadata operationMetadata)
@Deprecated public Attachment getAttachment(java.lang.String key)
IDatabaseCommands
getAttachment
in interface IDatabaseCommands
@Deprecated public Attachment headAttachment(java.lang.String key)
IDatabaseCommands
headAttachment
in interface IDatabaseCommands
@Deprecated protected Attachment directGetAttachment(HttpMethods method, java.lang.String key, OperationMetadata operationMetadata)
@Deprecated public void deleteAttachment(java.lang.String key, Etag etag)
IDatabaseCommands
deleteAttachment
in interface IDatabaseCommands
key
- The key.etag
- The etag.@Deprecated public AttachmentInformation[] getAttachments(int start, Etag startEtag, int pageSize)
getAttachments
in interface IDatabaseCommands
@Deprecated protected AttachmentInformation[] directGetAttachments(int start, Etag startEtag, int pageSize, OperationMetadata operationMetadata)
@Deprecated protected void directDeleteAttachment(java.lang.String key, Etag etag, OperationMetadata operationMetadata)
public TransformerDefinition getTransformer(java.lang.String name)
IDatabaseCommands
getTransformer
in interface IDatabaseCommands
public void deleteTransformer(java.lang.String name)
IDatabaseCommands
deleteTransformer
in interface IDatabaseCommands
protected void directDeleteTransformer(java.lang.String name, OperationMetadata operationMetadata)
protected TransformerDefinition directGetTransformer(java.lang.String transformerName, OperationMetadata operationMetadata)
public IndexDefinition getIndex(java.lang.String name)
IDatabaseCommands
getIndex
in interface IDatabaseCommands
protected IndexDefinition directGetIndex(java.lang.String indexName, OperationMetadata operationMetadata)
protected void directDelete(OperationMetadata operationMetadata, java.lang.String key, Etag etag) throws ServerClientException
ServerClientException
protected ConcurrencyException fetchConcurrencyException(HttpOperationException e)
public java.lang.String putTransformer(java.lang.String name, TransformerDefinition indexDef)
IDatabaseCommands
putTransformer
in interface IDatabaseCommands
public java.lang.String directPutTransformer(java.lang.String name, OperationMetadata operationMetadata, TransformerDefinition definition)
public QueryResult query(java.lang.String index, IndexQuery query)
IDatabaseCommands
query
in interface IDatabaseCommands
public QueryResult query(java.lang.String index, IndexQuery query, java.lang.String[] includes)
IDatabaseCommands
query
in interface IDatabaseCommands
public QueryResult query(java.lang.String index, IndexQuery query, java.lang.String[] includes, boolean metadataOnly)
IDatabaseCommands
query
in interface IDatabaseCommands
public QueryResult query(java.lang.String index, IndexQuery query, java.lang.String[] includes, boolean metadataOnly, boolean indexEntriesOnly)
IDatabaseCommands
query
in interface IDatabaseCommands
public RavenJObjectIterator streamQuery(java.lang.String index, IndexQuery query, Reference<QueryHeaderInformation> queryHeaderInfo)
IDatabaseCommands
streamQuery
in interface IDatabaseCommands
public RavenJObjectIterator streamDocs()
IDatabaseCommands
streamDocs
in interface IDatabaseCommands
public RavenJObjectIterator streamDocs(Etag fromEtag)
IDatabaseCommands
streamDocs
in interface IDatabaseCommands
public RavenJObjectIterator streamDocs(Etag fromEtag, java.lang.String startsWith)
IDatabaseCommands
streamDocs
in interface IDatabaseCommands
public RavenJObjectIterator streamDocs(Etag fromEtag, java.lang.String startsWith, java.lang.String matches)
IDatabaseCommands
streamDocs
in interface IDatabaseCommands
public RavenJObjectIterator streamDocs(Etag fromEtag, java.lang.String startsWith, java.lang.String matches, int start)
IDatabaseCommands
streamDocs
in interface IDatabaseCommands
public RavenJObjectIterator streamDocs(Etag fromEtag, java.lang.String startsWith, java.lang.String matches, int start, int pageSize)
IDatabaseCommands
streamDocs
in interface IDatabaseCommands
public RavenJObjectIterator streamDocs(Etag fromEtag, java.lang.String startsWith, java.lang.String matches, int start, int pageSize, java.lang.String exclude)
IDatabaseCommands
streamDocs
in interface IDatabaseCommands
public RavenJObjectIterator streamDocs(Etag fromEtag, java.lang.String startsWith, java.lang.String matches, int start, int pageSize, java.lang.String exclude, RavenPagingInformation pagingInformation)
IDatabaseCommands
streamDocs
in interface IDatabaseCommands
public RavenJObjectIterator streamDocs(Etag fromEtag, java.lang.String startsWith, java.lang.String matches, int start, int pageSize, java.lang.String exclude, RavenPagingInformation pagingInformation, java.lang.String skipAfter)
IDatabaseCommands
streamDocs
in interface IDatabaseCommands
protected QueryResult directQuery(HttpMethods method, java.lang.String index, IndexQuery query, OperationMetadata operationMetadata, java.lang.String[] includes, boolean metadataOnly, boolean includeEntries)
public void deleteIndex(java.lang.String name)
IDatabaseCommands
deleteIndex
in interface IDatabaseCommands
protected void directDeleteIndex(java.lang.String name, OperationMetadata operationMetadata)
public MultiLoadResult get(java.lang.String[] ids, java.lang.String[] includes)
IDatabaseCommands
get
in interface IDatabaseCommands
public MultiLoadResult get(java.lang.String[] ids, java.lang.String[] includes, java.lang.String transformer)
IDatabaseCommands
get
in interface IDatabaseCommands
public MultiLoadResult get(java.lang.String[] ids, java.lang.String[] includes, java.lang.String transformer, java.util.Map<java.lang.String,RavenJToken> transformerParameters)
IDatabaseCommands
get
in interface IDatabaseCommands
public MultiLoadResult get(java.lang.String[] ids, java.lang.String[] includes, java.lang.String transformer, java.util.Map<java.lang.String,RavenJToken> transformerParameters, boolean metadataOnly)
get
in interface IDatabaseCommands
protected MultiLoadResult directGet(java.lang.String[] ids, OperationMetadata operationMetadata, java.lang.String[] includes, java.lang.String transformer, java.util.Map<java.lang.String,RavenJToken> transformerParameters, boolean metadataOnly)
public BatchResult[] batch(java.util.List<ICommandData> commandDatas)
IDatabaseCommands
batch
in interface IDatabaseCommands
protected BatchResult[] directBatch(java.util.List<ICommandData> commandDatas, OperationMetadata operationMetadata)
public ILowLevelBulkInsertOperation getBulkInsertOperation(BulkInsertOptions options, IDatabaseChanges changes)
getBulkInsertOperation
in interface IDatabaseCommands
public java.lang.AutoCloseable forceReadFromMaster()
IDatabaseCommands
forceReadFromMaster
in interface IDatabaseCommands
public IDatabaseCommands forDatabase(java.lang.String database)
IDatabaseCommands
IDatabaseCommands
that will interacts with the specified databaseforDatabase
in interface IDatabaseCommands
public IDatabaseCommands forSystemDatabase()
IDatabaseCommands
IDatabaseCommands
that will interacts with the default database.forSystemDatabase
in interface IDatabaseCommands
public java.lang.String getUrl()
public Operation deleteByIndex(java.lang.String indexName, IndexQuery queryToDelete, BulkOperationOptions options)
deleteByIndex
in interface IDatabaseCommands
indexName
- queryToDelete
- options
- protected Operation directDeleteByIndex(OperationMetadata operationMetadata, java.lang.String indexName, IndexQuery queryToDelete, BulkOperationOptions options)
public Operation updateByIndex(java.lang.String indexName, IndexQuery queryToUpdate, PatchRequest[] patchRequests)
updateByIndex
in interface IDatabaseCommands
indexName
- queryToUpdate
- patchRequests
- public Operation updateByIndex(java.lang.String indexName, IndexQuery queryToUpdate, ScriptedPatchRequest patch)
updateByIndex
in interface IDatabaseCommands
indexName
- queryToUpdate
- patch
- public Operation updateByIndex(java.lang.String indexName, IndexQuery queryToUpdate, PatchRequest[] patchRequests, BulkOperationOptions options)
updateByIndex
in interface IDatabaseCommands
indexName
- queryToUpdate
- patchRequests
- options
- public Operation updateByIndex(java.lang.String indexName, IndexQuery queryToUpdate, ScriptedPatchRequest patch, BulkOperationOptions options)
updateByIndex
in interface IDatabaseCommands
indexName
- queryToUpdate
- patch
- options
- protected Operation directUpdateByIndexImpl(OperationMetadata operationMetadata, java.lang.String indexName, IndexQuery queryToUpdate, BulkOperationOptions options, java.lang.String requestData, HttpMethods method)
public Operation deleteByIndex(java.lang.String indexName, IndexQuery queryToDelete)
deleteByIndex
in interface IDatabaseCommands
indexName
- queryToDelete
- public SuggestionQueryResult suggest(java.lang.String index, SuggestionQuery suggestionQuery)
IDatabaseCommands
suggest
in interface IDatabaseCommands
public MultiLoadResult moreLikeThis(MoreLikeThisQuery query)
IDatabaseCommands
moreLikeThis
in interface IDatabaseCommands
protected SuggestionQueryResult directSuggest(java.lang.String index, SuggestionQuery suggestionQuery, OperationMetadata operationMetadata)
public DatabaseStatistics getStatistics()
IDatabaseCommands
getStatistics
in interface IDatabaseCommands
public java.lang.Long nextIdentityFor(java.lang.String name)
IDatabaseCommands
nextIdentityFor
in interface IDatabaseCommands
protected java.lang.Long directNextIdentityFor(java.lang.String name, OperationMetadata operationMetadata)
public long seedIdentityFor(java.lang.String name, long value)
seedIdentityFor
in interface IDatabaseCommands
name
- value
- public java.lang.String urlFor(java.lang.String documentKey)
IDatabaseCommands
urlFor
in interface IDatabaseCommands
public JsonDocumentMetadata head(java.lang.String key)
IDatabaseCommands
head
in interface IDatabaseCommands
key
- The key.protected JsonDocumentMetadata directHead(OperationMetadata operationMetadata, java.lang.String key)
public GetResponse[] multiGet(GetRequest[] requests)
multiGet
in interface IDatabaseCommands
requests
- protected GetResponse[] directMultiGet(OperationMetadata operationMetadata, GetRequest[] requests)
public java.util.List<java.lang.String> getTerms(java.lang.String index, java.lang.String field, java.lang.String fromValue, int pageSize)
IDatabaseCommands
getTerms
in interface IDatabaseCommands
protected java.util.List<java.lang.String> directGetTerms(OperationMetadata operationMetadata, java.lang.String index, java.lang.String field, java.lang.String fromValue, int pageSize)
public FacetResults getFacets(java.lang.String index, IndexQuery query, java.lang.String facetSetupDoc)
getFacets
in interface IDatabaseCommands
index
- query
- facetSetupDoc
- public FacetResults getFacets(java.lang.String index, IndexQuery query, java.lang.String facetSetupDoc, int start)
getFacets
in interface IDatabaseCommands
index
- query
- facetSetupDoc
- start
- public FacetResults getFacets(java.lang.String index, IndexQuery query, java.lang.String facetSetupDoc, int start, java.lang.Integer pageSize)
getFacets
in interface IDatabaseCommands
index
- query
- facetSetupDoc
- start
- pageSize
- protected FacetResults directGetFacets(OperationMetadata operationMetadata, java.lang.String index, IndexQuery query, java.lang.String facetSetupDoc, int start, java.lang.Integer pageSize)
public FacetResults getFacets(java.lang.String index, IndexQuery query, java.util.List<Facet> facets)
getFacets
in interface IDatabaseCommands
index
- query
- facets
- public FacetResults getFacets(java.lang.String index, IndexQuery query, java.util.List<Facet> facets, int start)
getFacets
in interface IDatabaseCommands
index
- query
- facets
- start
- public FacetResults getFacets(java.lang.String index, IndexQuery query, java.util.List<Facet> facets, int start, java.lang.Integer pageSize)
getFacets
in interface IDatabaseCommands
index
- query
- facets
- start
- pageSize
- protected FacetResults directGetFacets(OperationMetadata operationMetadata, java.lang.String index, IndexQuery query, java.lang.String facetsJson, int start, java.lang.Integer pageSize, HttpMethods method)
public FacetResults[] getMultiFacets(FacetQuery[] facetedQueries)
IDatabaseCommands
getMultiFacets
in interface IDatabaseCommands
protected FacetResults[] directGetMultiFacets(OperationMetadata operationMetadata, FacetQuery[] facetedQueries)
public RavenJObject patch(java.lang.String key, PatchRequest[] patches)
patch
in interface IDatabaseCommands
key
- patches
- public RavenJObject patch(java.lang.String key, PatchRequest[] patches, boolean ignoreMissing)
patch
in interface IDatabaseCommands
key
- patches
- ignoreMissing
- public RavenJObject patch(java.lang.String key, ScriptedPatchRequest patch)
patch
in interface IDatabaseCommands
key
- patch
- public RavenJObject patch(java.lang.String key, ScriptedPatchRequest patch, boolean ignoreMissing)
patch
in interface IDatabaseCommands
key
- patch
- ignoreMissing
- public RavenJObject patch(java.lang.String key, PatchRequest[] patches, Etag etag)
patch
in interface IDatabaseCommands
key
- patches
- etag
- public RavenJObject patch(java.lang.String key, PatchRequest[] patchesToExisting, PatchRequest[] patchesToDefault, RavenJObject defaultMetadata)
patch
in interface IDatabaseCommands
key
- patchesToExisting
- patchesToDefault
- defaultMetadata
- public RavenJObject patch(java.lang.String key, ScriptedPatchRequest patch, Etag etag)
patch
in interface IDatabaseCommands
key
- patch
- etag
- public RavenJObject patch(java.lang.String key, ScriptedPatchRequest patchExisting, ScriptedPatchRequest patchDefault, RavenJObject defaultMetadata)
patch
in interface IDatabaseCommands
key
- patchExisting
- patchDefault
- defaultMetadata
- public java.lang.AutoCloseable disableAllCaching()
IDatabaseCommands
disableAllCaching
in interface IDatabaseCommands
public ProfilingInformation getProfilingInformation()
IHoldProfilingInformation
getProfilingInformation
in interface IHoldProfilingInformation
public RavenJToken getOperationStatus(long id)
public boolean isExpect100Continue()
IHoldProfilingInformation
isExpect100Continue
in interface IHoldProfilingInformation
public void setExpect100Continue(boolean expect100Continue)
public IAdminDatabaseCommands getAdmin()
getAdmin
in interface IDatabaseCommands
public IGlobalAdminDatabaseCommands getGlobalAdmin()
IDatabaseCommands
getGlobalAdmin
in interface IDatabaseCommands
public java.lang.Boolean tryResolveConflictByUsingRegisteredListeners(java.lang.String key, Etag etag, java.lang.String[] conflictedIds, OperationMetadata operationMetadata)
IDatabaseCommands
tryResolveConflictByUsingRegisteredListeners
in interface IDatabaseCommands
public java.lang.String getSingleAuthToken()
public ReplicationDocument directGetReplicationDestinations(OperationMetadata operationMetadata)
Copyright © 2014. All Rights Reserved.