public class RDBDocumentStoreJDBC
extends java.lang.Object
RDBDocumentStore
.Constructor and Description |
---|
RDBDocumentStoreJDBC(RDBDocumentStoreDB dbInfo,
RDBDocumentSerializer ser,
int queryHitsLimit,
int queryTimeLimit) |
Modifier and Type | Method and Description |
---|---|
boolean |
appendingUpdate(java.sql.Connection connection,
org.apache.jackrabbit.oak.plugins.document.rdb.RDBDocumentStore.RDBTableMetaData tmd,
java.lang.String id,
java.lang.Long modified,
boolean setModifiedConditionally,
java.lang.Number hasBinary,
java.lang.Boolean deletedOnce,
java.lang.Long modcount,
java.lang.Long cmodcount,
java.lang.Long oldmodcount,
java.lang.String appendData) |
int |
delete(java.sql.Connection connection,
org.apache.jackrabbit.oak.plugins.document.rdb.RDBDocumentStore.RDBTableMetaData tmd,
java.util.List<java.lang.String> allIds) |
int |
delete(java.sql.Connection connection,
org.apache.jackrabbit.oak.plugins.document.rdb.RDBDocumentStore.RDBTableMetaData tmd,
java.util.Map<java.lang.String,java.lang.Long> toDelete) |
int |
deleteWithCondition(java.sql.Connection connection,
org.apache.jackrabbit.oak.plugins.document.rdb.RDBDocumentStore.RDBTableMetaData tmd,
java.util.List<RDBDocumentStore.QueryCondition> conditions) |
long |
determineServerTimeDifferenceMillis(java.sql.Connection connection) |
long |
getLong(java.sql.Connection connection,
org.apache.jackrabbit.oak.plugins.document.rdb.RDBDocumentStore.RDBTableMetaData tmd,
java.lang.String aggregate,
java.lang.String field,
java.lang.String minId,
java.lang.String maxId,
java.util.List<java.lang.String> excludeKeyPatterns,
java.util.List<RDBDocumentStore.QueryCondition> conditions) |
<T extends Document> |
insert(java.sql.Connection connection,
org.apache.jackrabbit.oak.plugins.document.rdb.RDBDocumentStore.RDBTableMetaData tmd,
java.util.List<T> documents) |
@NotNull java.util.List<RDBRow> |
query(java.sql.Connection connection,
org.apache.jackrabbit.oak.plugins.document.rdb.RDBDocumentStore.RDBTableMetaData tmd,
java.lang.String minId,
java.lang.String maxId,
java.util.List<java.lang.String> excludeKeyPatterns,
java.util.List<RDBDocumentStore.QueryCondition> conditions,
int limit) |
@NotNull java.util.Iterator<RDBRow> |
queryAsIterator(RDBConnectionHandler ch,
org.apache.jackrabbit.oak.plugins.document.rdb.RDBDocumentStore.RDBTableMetaData tmd,
java.lang.String minId,
java.lang.String maxId,
java.util.List<java.lang.String> excludeKeyPatterns,
java.util.List<RDBDocumentStore.QueryCondition> conditions,
int limit,
java.lang.String sortBy) |
java.util.List<RDBRow> |
read(java.sql.Connection connection,
org.apache.jackrabbit.oak.plugins.document.rdb.RDBDocumentStore.RDBTableMetaData tmd,
java.util.Collection<java.lang.String> allKeys) |
@Nullable RDBRow |
read(java.sql.Connection connection,
org.apache.jackrabbit.oak.plugins.document.rdb.RDBDocumentStore.RDBTableMetaData tmd,
java.lang.String id,
long lastmodcount,
long lastmodified) |
<T extends Document> |
update(java.sql.Connection connection,
org.apache.jackrabbit.oak.plugins.document.rdb.RDBDocumentStore.RDBTableMetaData tmd,
java.util.List<T> documents,
boolean upsert)
Update a list of documents using JDBC batches.
|
boolean |
update(java.sql.Connection connection,
org.apache.jackrabbit.oak.plugins.document.rdb.RDBDocumentStore.RDBTableMetaData tmd,
java.lang.String id,
java.lang.Long modified,
java.lang.Number hasBinary,
java.lang.Boolean deletedOnce,
java.lang.Long modcount,
java.lang.Long cmodcount,
java.lang.Long oldmodcount,
java.lang.String data) |
public RDBDocumentStoreJDBC(RDBDocumentStoreDB dbInfo, RDBDocumentSerializer ser, int queryHitsLimit, int queryTimeLimit)
public boolean appendingUpdate(java.sql.Connection connection, org.apache.jackrabbit.oak.plugins.document.rdb.RDBDocumentStore.RDBTableMetaData tmd, java.lang.String id, java.lang.Long modified, boolean setModifiedConditionally, java.lang.Number hasBinary, java.lang.Boolean deletedOnce, java.lang.Long modcount, java.lang.Long cmodcount, java.lang.Long oldmodcount, java.lang.String appendData) throws java.sql.SQLException
java.sql.SQLException
public int delete(java.sql.Connection connection, org.apache.jackrabbit.oak.plugins.document.rdb.RDBDocumentStore.RDBTableMetaData tmd, java.util.List<java.lang.String> allIds) throws java.sql.SQLException
java.sql.SQLException
public int delete(java.sql.Connection connection, org.apache.jackrabbit.oak.plugins.document.rdb.RDBDocumentStore.RDBTableMetaData tmd, java.util.Map<java.lang.String,java.lang.Long> toDelete) throws java.sql.SQLException
java.sql.SQLException
public int deleteWithCondition(java.sql.Connection connection, org.apache.jackrabbit.oak.plugins.document.rdb.RDBDocumentStore.RDBTableMetaData tmd, java.util.List<RDBDocumentStore.QueryCondition> conditions) throws java.sql.SQLException, DocumentStoreException
java.sql.SQLException
DocumentStoreException
public long determineServerTimeDifferenceMillis(java.sql.Connection connection)
public <T extends Document> java.util.Set<java.lang.String> insert(java.sql.Connection connection, org.apache.jackrabbit.oak.plugins.document.rdb.RDBDocumentStore.RDBTableMetaData tmd, java.util.List<T> documents) throws java.sql.SQLException
java.sql.SQLException
public <T extends Document> java.util.Set<java.lang.String> update(java.sql.Connection connection, org.apache.jackrabbit.oak.plugins.document.rdb.RDBDocumentStore.RDBTableMetaData tmd, java.util.List<T> documents, boolean upsert) throws java.sql.SQLException
If the upsert
parameter is set to true, the method will also try to insert new documents, those
which modcount equals to 1.
The order of applying updates will be different than order of the passed list, so there shouldn't be two
updates related to the same document. An IllegalArgumentException
will be thrown if there are.
connection
- JDBC connectiontmd
- Table metadatadocuments
- List of documents to updateupsert
- Insert new documentsjava.sql.SQLException
@NotNull public @NotNull java.util.List<RDBRow> query(java.sql.Connection connection, org.apache.jackrabbit.oak.plugins.document.rdb.RDBDocumentStore.RDBTableMetaData tmd, java.lang.String minId, java.lang.String maxId, java.util.List<java.lang.String> excludeKeyPatterns, java.util.List<RDBDocumentStore.QueryCondition> conditions, int limit) throws java.sql.SQLException
java.sql.SQLException
public long getLong(java.sql.Connection connection, org.apache.jackrabbit.oak.plugins.document.rdb.RDBDocumentStore.RDBTableMetaData tmd, java.lang.String aggregate, java.lang.String field, java.lang.String minId, java.lang.String maxId, java.util.List<java.lang.String> excludeKeyPatterns, java.util.List<RDBDocumentStore.QueryCondition> conditions) throws java.sql.SQLException
java.sql.SQLException
@NotNull public @NotNull java.util.Iterator<RDBRow> queryAsIterator(RDBConnectionHandler ch, org.apache.jackrabbit.oak.plugins.document.rdb.RDBDocumentStore.RDBTableMetaData tmd, java.lang.String minId, java.lang.String maxId, java.util.List<java.lang.String> excludeKeyPatterns, java.util.List<RDBDocumentStore.QueryCondition> conditions, int limit, java.lang.String sortBy) throws java.sql.SQLException
java.sql.SQLException
public java.util.List<RDBRow> read(java.sql.Connection connection, org.apache.jackrabbit.oak.plugins.document.rdb.RDBDocumentStore.RDBTableMetaData tmd, java.util.Collection<java.lang.String> allKeys) throws java.sql.SQLException
java.sql.SQLException
@Nullable public @Nullable RDBRow read(java.sql.Connection connection, org.apache.jackrabbit.oak.plugins.document.rdb.RDBDocumentStore.RDBTableMetaData tmd, java.lang.String id, long lastmodcount, long lastmodified) throws java.sql.SQLException
java.sql.SQLException
public boolean update(java.sql.Connection connection, org.apache.jackrabbit.oak.plugins.document.rdb.RDBDocumentStore.RDBTableMetaData tmd, java.lang.String id, java.lang.Long modified, java.lang.Number hasBinary, java.lang.Boolean deletedOnce, java.lang.Long modcount, java.lang.Long cmodcount, java.lang.Long oldmodcount, java.lang.String data) throws java.sql.SQLException
java.sql.SQLException
Copyright © 2012–2022 The Apache Software Foundation. All rights reserved.