import org.ektorp.support.CouchDbDocument; //导入依赖的package包/类
public void importRecordsWihtServerName(List<T> records, String serverName) throws Exception {
    for (T source : records) {
            try {
            	((CouchDbDocument) source).setRevision(null);
            	if (source.getClass().getSimpleName().equalsIgnoreCase("TriggerRecord")){
            		if( ((TriggerRecord) source).getServerName() == null )
            				((TriggerRecord) source).setServerName(serverName);
            		
            	}
            	else if (source.getClass().getSimpleName().equalsIgnoreCase("BoundApp")){
            		if (((BoundApp) source).getServerName() == null) 
            			((BoundApp) source).setServerName(serverName);
            	}
            	update(source);
            } catch (org.ektorp.UpdateConflictException e) {
            	logger.error("Error:" , e);
            }
        }
}
 

import org.ektorp.support.CouchDbDocument; //导入依赖的package包/类
public void importRecords(List<T> records) throws Exception {
    for (T source : records) {
            try {
            	((CouchDbDocument) source).setRevision(null);
                update(source);
            } catch (org.ektorp.UpdateConflictException e) {
            	logger.error("Error:" , e);
            }
        }
}
 

import org.ektorp.support.CouchDbDocument; //导入依赖的package包/类
/**
 * Initialize the data store by reading the credentials, setting the client's properties up and
 * reading the mapping file. Initialize is called when then the call to
 * {@link org.apache.gora.store.DataStoreFactory#createDataStore} is made.
 *
 * @param keyClass
 * @param persistentClass
 * @param properties
 */
@Override
public void initialize(Class<K> keyClass, Class<T> persistentClass, Properties properties) {
  LOG.debug("Initializing CouchDB store");
  super.initialize(keyClass, persistentClass, properties);

  final CouchDBParameters params = CouchDBParameters.load(properties);

  try {
    final String mappingFile = DataStoreFactory.getMappingFile(properties, this, DEFAULT_MAPPING_FILE);
    final HttpClient httpClient = new StdHttpClient.Builder()
        .url("http://" + params.getServer() + ":" + params.getPort())
        .build();

    dbInstance = new StdCouchDbInstance(httpClient);

    final CouchDBMappingBuilder<K, T> builder = new CouchDBMappingBuilder<>(this);
    LOG.debug("Initializing CouchDB store with mapping {}.", new Object[] { mappingFile });
    builder.readMapping(mappingFile);
    mapping = builder.build();

    final ObjectMapperFactory myObjectMapperFactory = new CouchDBObjectMapperFactory();
    myObjectMapperFactory.createObjectMapper().addMixInAnnotations(persistentClass, CouchDbDocument.class);

    db = new StdCouchDbConnector(mapping.getDatabaseName(), dbInstance, myObjectMapperFactory);
    db.createDatabaseIfNotExists();

  } catch (IOException e) {
    LOG.error("Error while initializing CouchDB store: {}", new Object[] { e.getMessage() });
    throw new RuntimeException(e);
  }
}
 

import org.ektorp.support.CouchDbDocument; //导入依赖的package包/类
public static CouchDbDocument transform( final BaseObject obj ) {
	CouchDbDocument cdd = new CouchDbDocument();
	
	return cdd;
}