com.heitaox.sql.executor.source.nosql

类 MongoDataSource

java.lang.Object

com.heitaox.sql.executor.source.nosql.MongoDataSource

所有已实现的接口:

DataSource, NoSQLDataSource

public class MongoDataSource
extends Object
implements NoSQLDataSource

构造器概要

构造器

构造器和说明
MongoDataSource(List<com.mongodb.ServerAddress> serverAddreses, String dbName)
MongoDataSource(com.mongodb.client.MongoClient mongoClient, String dbName)
MongoDataSource(MongoDataSourceProperties properties)
MongoDataSource(String host, Integer port, String dbName)

方法概要

限定符和类型	方法和说明
void	closeMongoClient()
int	delete(List<PredicateEntity<Object>> predicateEntities, String tableName)
int	insert(List<Map<String,Object>> valueList, String tableName)
joinery.DataFrame	queryAll(String tableNme, String tableAlias)
joinery.DataFrame	queryByPredicate(String table, String tableAlias, List<PredicateEntity<Object>> predicateEntities)
int	update(Map<String,Object> updateItems, List<PredicateEntity<Object>> predicateEntities, String tableName)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

MongoDataSource

public MongoDataSource(MongoDataSourceProperties properties)

MongoDataSource

public MongoDataSource(String host,
                       Integer port,
                       String dbName)

MongoDataSource

public MongoDataSource(List<com.mongodb.ServerAddress> serverAddreses,
                       String dbName)

MongoDataSource

public MongoDataSource(com.mongodb.client.MongoClient mongoClient,
                       String dbName)

方法详细资料

queryAll

public joinery.DataFrame queryAll(String tableNme,
                                  String tableAlias)

指定者:

queryAll 在接口中 DataSource

queryByPredicate

public joinery.DataFrame queryByPredicate(String table,
                                          String tableAlias,
                                          List<PredicateEntity<Object>> predicateEntities)

指定者:

queryByPredicate 在接口中 DataSource

insert

public int insert(List<Map<String,Object>> valueList,
                  String tableName)

指定者:

insert 在接口中 DataSource

update

public int update(Map<String,Object> updateItems,
                  List<PredicateEntity<Object>> predicateEntities,
                  String tableName)
           throws IOException

指定者:

update 在接口中 DataSource

抛出:

IOException

delete

public int delete(List<PredicateEntity<Object>> predicateEntities,
                  String tableName)

指定者:

delete 在接口中 DataSource

closeMongoClient

public void closeMongoClient()