Package io.jans.orm.couchbase.operation.impl

Class CouchbaseOperationServiceImpl

java.lang.Object
io.jans.orm.couchbase.operation.impl.CouchbaseOperationServiceImpl
All Implemented Interfaces:
CouchbaseOperationService, io.jans.orm.operation.PersistenceOperationService
public class CouchbaseOperationServiceImpl extends Object implements CouchbaseOperationService
Base service which performs all supported Couchbase operations
Author:
Yuriy Movchan Date: 05/10/2018

  • Constructor Details

    • CouchbaseOperationServiceImpl

      public CouchbaseOperationServiceImpl()

    • CouchbaseOperationServiceImpl

      public CouchbaseOperationServiceImpl(Properties props, CouchbaseConnectionProvider connectionProvider)

  • Method Details

    • getConnectionProvider

      public CouchbaseConnectionProvider getConnectionProvider()
      Specified by:
      getConnectionProvider in interface CouchbaseOperationService

    • authenticate

      public boolean authenticate(String key, String password, String objectClass) throws io.jans.orm.exception.operation.ConnectionException, io.jans.orm.exception.operation.SearchException, io.jans.orm.exception.AuthenticationException
      Specified by:
      authenticate in interface io.jans.orm.operation.PersistenceOperationService
      Throws:
      io.jans.orm.exception.operation.ConnectionException
      io.jans.orm.exception.operation.SearchException
      io.jans.orm.exception.AuthenticationException

    • addEntry

      public boolean addEntry(String key, com.couchbase.client.java.json.JsonObject jsonObject) throws io.jans.orm.exception.operation.DuplicateEntryException, io.jans.orm.exception.operation.PersistenceException
      Specified by:
      addEntry in interface CouchbaseOperationService
      Throws:
      io.jans.orm.exception.operation.DuplicateEntryException
      io.jans.orm.exception.operation.PersistenceException

    • addEntry

      public boolean addEntry(String key, com.couchbase.client.java.json.JsonObject jsonObject, Integer expiration) throws io.jans.orm.exception.operation.DuplicateEntryException, io.jans.orm.exception.operation.PersistenceException
      Specified by:
      addEntry in interface CouchbaseOperationService
      Throws:
      io.jans.orm.exception.operation.DuplicateEntryException
      io.jans.orm.exception.operation.PersistenceException

    • updateEntry

      @Deprecated protected boolean updateEntry(String key, com.couchbase.client.java.json.JsonObject attrs) throws UnsupportedOperationException, io.jans.orm.exception.operation.PersistenceException
      Deprecated.
      Throws:
      UnsupportedOperationException
      io.jans.orm.exception.operation.PersistenceException

    • updateEntry

      public boolean updateEntry(String key, List<com.couchbase.client.java.kv.MutateInSpec> mods, Integer expiration) throws io.jans.orm.exception.operation.PersistenceException
      Specified by:
      updateEntry in interface CouchbaseOperationService
      Throws:
      io.jans.orm.exception.operation.PersistenceException

    • delete

      public boolean delete(String key) throws io.jans.orm.exception.operation.EntryNotFoundException
      Specified by:
      delete in interface CouchbaseOperationService
      Throws:
      io.jans.orm.exception.operation.EntryNotFoundException

    • delete

      public int delete(String key, com.couchbase.client.java.query.QueryScanConsistency queryScanConsistency, ConvertedExpression expression, int count) throws io.jans.orm.exception.operation.DeleteException
      Specified by:
      delete in interface CouchbaseOperationService
      Throws:
      io.jans.orm.exception.operation.DeleteException

    • deleteRecursively

      public boolean deleteRecursively(String key) throws io.jans.orm.exception.operation.EntryNotFoundException, io.jans.orm.exception.operation.DeleteException
      Specified by:
      deleteRecursively in interface CouchbaseOperationService
      Throws:
      io.jans.orm.exception.operation.EntryNotFoundException
      io.jans.orm.exception.operation.DeleteException

    • lookup

      public com.couchbase.client.java.json.JsonObject lookup(String key, String... attributes) throws io.jans.orm.exception.operation.SearchException
      Specified by:
      lookup in interface CouchbaseOperationService
      Throws:
      io.jans.orm.exception.operation.SearchException

    • search

      public <O> io.jans.orm.model.PagedResult<com.couchbase.client.java.json.JsonObject> search(String key, com.couchbase.client.java.query.QueryScanConsistency queryScanConsistency, ConvertedExpression expression, io.jans.orm.model.SearchScope scope, String[] attributes, io.jans.orm.model.Sort[] orderBy, CouchbaseBatchOperationWraper<O> batchOperationWraper, SearchReturnDataType returnDataType, int start, int count, int pageSize) throws io.jans.orm.exception.operation.SearchException
      Specified by:
      search in interface CouchbaseOperationService
      Throws:
      io.jans.orm.exception.operation.SearchException

    • createStoragePassword

      public String[] createStoragePassword(String[] passwords, io.jans.orm.model.AttributeData attributeData)
      Specified by:
      createStoragePassword in interface CouchbaseOperationService

    • isBinaryAttribute

      public boolean isBinaryAttribute(String attribute)
      Specified by:
      isBinaryAttribute in interface CouchbaseOperationService

    • isCertificateAttribute

      public boolean isCertificateAttribute(String attribute)
      Specified by:
      isCertificateAttribute in interface CouchbaseOperationService

    • getQueryScanConsistency

      public com.couchbase.client.java.query.QueryScanConsistency getQueryScanConsistency()

    • isDisableAttributeMapping

      public boolean isDisableAttributeMapping()

    • destroy

      public boolean destroy()
      Specified by:
      destroy in interface CouchbaseOperationService

    • isConnected

      public boolean isConnected()
      Specified by:
      isConnected in interface io.jans.orm.operation.PersistenceOperationService

    • getScanAttemptLogInfo

      protected String getScanAttemptLogInfo(com.couchbase.client.java.query.QueryScanConsistency queryScanConsistency, com.couchbase.client.java.query.QueryScanConsistency usedQueryScanConsistency, boolean secondTry)

    • setPersistenceExtension

      public void setPersistenceExtension(io.jans.orm.extension.PersistenceExtension persistenceExtension)
      Specified by:
      setPersistenceExtension in interface io.jans.orm.operation.PersistenceOperationService

    • isSupportObjectClass

      public boolean isSupportObjectClass(String objectClass)
      Specified by:
      isSupportObjectClass in interface io.jans.orm.operation.PersistenceOperationService

    • toInternalAttribute

      public String toInternalAttribute(String attributeName)
      Specified by:
      toInternalAttribute in interface CouchbaseOperationService

    • toInternalAttributes

      public String[] toInternalAttributes(String[] attributeNames)
      Specified by:
      toInternalAttributes in interface CouchbaseOperationService

    • fromInternalAttribute

      public String fromInternalAttribute(String internalAttributeName)
      Specified by:
      fromInternalAttribute in interface CouchbaseOperationService

    • fromInternalAttributes

      public String[] fromInternalAttributes(String[] internalAttributeNames)
      Specified by:
      fromInternalAttributes in interface CouchbaseOperationService

    • encodeTime

      public String encodeTime(Date date)
      Specified by:
      encodeTime in interface CouchbaseOperationService

    • decodeTime

      public Date decodeTime(String date, boolean silent)
      Specified by:
      decodeTime in interface CouchbaseOperationService

    • getPersistenceMetadata

      public io.jans.orm.model.PersistenceMetadata getPersistenceMetadata(String primaryKey)
      Specified by:
      getPersistenceMetadata in interface io.jans.orm.operation.PersistenceOperationService

    • getTableColumnsMap

      public Map<String,Map<String,io.jans.orm.model.AttributeType>> getTableColumnsMap()
      Specified by:
      getTableColumnsMap in interface io.jans.orm.operation.PersistenceOperationService