cn.geekcity.xiot.support.vertx.database.proxy.impl

类 DatabaseProxyJdbcImpl

java.lang.Object

cn.geekcity.xiot.support.vertx.database.proxy.impl.DatabaseProxyJdbcImpl

所有已实现的接口:

DatabaseProxy

public class DatabaseProxyJdbcImpl
extends java.lang.Object
implements DatabaseProxy

构造器概要

构造器

构造器和说明
DatabaseProxyJdbcImpl(io.vertx.core.Vertx vertx, io.vertx.core.json.JsonObject config)

方法概要

限定符和类型	方法和说明
io.vertx.core.Future<java.lang.Void>	bulkInsert(java.lang.String traceId, java.lang.String table, java.util.List<java.util.Map<java.lang.String,java.lang.Object>> list) INSERT INTO DEVICE (DID, TYPE, ONLINE) VALUES ('aaa', 'xxx', 1), ('bbb', 'xxx', 1);
io.vertx.core.Future<java.lang.Void>	bulkUpsert(java.lang.String traceId, java.lang.String table, java.lang.String key, java.util.List<java.util.Map<java.lang.String,java.lang.Object>> list) INSERT INTO DEVICE (DID, TYPE, ONLINE) VALUES ('aaa', 'xxx', 1), ('bbb', 'xxx', 1) ON DUPLICATE KEY UPDATE DID=VALUES(DID), TYPE=VALUES(TYPE), ONLINE=VALUES(ONLINE);
io.vertx.core.Future<java.lang.Void>	close()
io.vertx.core.Future<java.lang.Integer>	count(java.lang.String traceId, java.lang.String table)
io.vertx.core.Future<java.lang.Integer>	count(java.lang.String traceId, java.lang.String table, java.lang.String selection, java.lang.String[] selectionArgs)
io.vertx.core.Future<java.lang.Void>	delete(java.lang.String traceId, java.lang.String table) DELETE FROM DEVICE
io.vertx.core.Future<java.lang.Void>	delete(java.lang.String traceId, java.lang.String table, java.lang.String selection, java.lang.String[] selectionArgs)
io.vertx.core.Future<io.vertx.core.json.JsonArray>	execSQL(java.lang.String traceId, java.lang.String sql)
io.vertx.core.Future<java.lang.Boolean>	exists(java.lang.String traceId, java.lang.String table)
io.vertx.core.Future<java.lang.Void>	insert(java.lang.String traceId, java.lang.String table, java.util.Map<java.lang.String,java.lang.Object> values) INSERT INTO DEVICE (DID, TYPE, ONLINE) VALUES ('aaa', 'xxx', 1);
io.vertx.core.Future<java.util.List<java.util.Map<java.lang.String,java.lang.Object>>>	query(java.lang.String traceId, java.lang.String table, java.lang.String[] fields) SELECT (DID, TYPE, ONLINE) FROM DEVICE;
io.vertx.core.Future<java.util.List<java.util.Map<java.lang.String,java.lang.Object>>>	query(java.lang.String traceId, java.lang.String table, java.lang.String[] fields, java.lang.String selection, java.lang.String[] selectionArgs)
io.vertx.core.Future<java.util.Map<java.lang.String,java.lang.Object>>	queryOne(java.lang.String traceId, java.lang.String table, java.lang.String[] fields, java.lang.String selection, java.lang.String[] selectionArgs)
io.vertx.core.Future<java.util.List<java.util.Map<java.lang.String,java.lang.Object>>>	rawQuery(java.lang.String traceId, java.lang.String sql, java.lang.String[] selectionArgs)
io.vertx.core.Future<java.util.Map<java.lang.String,java.lang.Object>>	rawQueryOne(java.lang.String traceId, java.lang.String sql, java.lang.String[] selectionArgs)
io.vertx.core.Future<java.lang.Void>	update(java.lang.String traceId, java.lang.String table, java.util.Map<java.lang.String,java.lang.Object> values)
io.vertx.core.Future<java.lang.Void>	update(java.lang.String traceId, java.lang.String table, java.util.Map<java.lang.String,java.lang.Object> values, java.lang.String where, java.lang.String[] selectionArgs)
io.vertx.core.Future<java.lang.Void>	upsert(java.lang.String traceId, java.lang.String table, java.lang.String key, java.util.Map<java.lang.String,java.lang.Object> values) INSERT INTO device_summary (did, type, online, accesspoint, bridge, timestamp) VALUES (?

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

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

从接口继承的方法 cn.geekcity.xiot.support.vertx.database.proxy.DatabaseProxy

create

构造器详细资料

DatabaseProxyJdbcImpl

public DatabaseProxyJdbcImpl(io.vertx.core.Vertx vertx,
                             io.vertx.core.json.JsonObject config)

方法详细资料

exists

public io.vertx.core.Future<java.lang.Boolean> exists(java.lang.String traceId,
                                                      java.lang.String table)

指定者:

exists 在接口中 DatabaseProxy

execSQL

public io.vertx.core.Future<io.vertx.core.json.JsonArray> execSQL(java.lang.String traceId,
                                                                  java.lang.String sql)

指定者:

execSQL 在接口中 DatabaseProxy

rawQuery

public io.vertx.core.Future<java.util.List<java.util.Map<java.lang.String,java.lang.Object>>> rawQuery(java.lang.String traceId,
                                                                                                       java.lang.String sql,
                                                                                                       java.lang.String[] selectionArgs)

指定者:

rawQuery 在接口中 DatabaseProxy

rawQueryOne

public io.vertx.core.Future<java.util.Map<java.lang.String,java.lang.Object>> rawQueryOne(java.lang.String traceId,
                                                                                          java.lang.String sql,
                                                                                          java.lang.String[] selectionArgs)

指定者:

rawQueryOne 在接口中 DatabaseProxy

query

public io.vertx.core.Future<java.util.List<java.util.Map<java.lang.String,java.lang.Object>>> query(java.lang.String traceId,
                                                                                                    java.lang.String table,
                                                                                                    java.lang.String[] fields)

SELECT (DID, TYPE, ONLINE) FROM DEVICE;

指定者:

query 在接口中 DatabaseProxy

query

public io.vertx.core.Future<java.util.List<java.util.Map<java.lang.String,java.lang.Object>>> query(java.lang.String traceId,
                                                                                                    java.lang.String table,
                                                                                                    java.lang.String[] fields,
                                                                                                    java.lang.String selection,
                                                                                                    java.lang.String[] selectionArgs)

指定者:

query 在接口中 DatabaseProxy

queryOne

public io.vertx.core.Future<java.util.Map<java.lang.String,java.lang.Object>> queryOne(java.lang.String traceId,
                                                                                       java.lang.String table,
                                                                                       java.lang.String[] fields,
                                                                                       java.lang.String selection,
                                                                                       java.lang.String[] selectionArgs)

指定者:

queryOne 在接口中 DatabaseProxy

bulkInsert

public io.vertx.core.Future<java.lang.Void> bulkInsert(java.lang.String traceId,
                                                       java.lang.String table,
                                                       java.util.List<java.util.Map<java.lang.String,java.lang.Object>> list)

INSERT INTO DEVICE (DID, TYPE, ONLINE) VALUES ('aaa', 'xxx', 1), ('bbb', 'xxx', 1);

指定者:

bulkInsert 在接口中 DatabaseProxy

bulkUpsert

public io.vertx.core.Future<java.lang.Void> bulkUpsert(java.lang.String traceId,
                                                       java.lang.String table,
                                                       java.lang.String key,
                                                       java.util.List<java.util.Map<java.lang.String,java.lang.Object>> list)

INSERT INTO DEVICE (DID, TYPE, ONLINE) VALUES ('aaa', 'xxx', 1), ('bbb', 'xxx', 1) ON DUPLICATE KEY UPDATE DID=VALUES(DID), TYPE=VALUES(TYPE), ONLINE=VALUES(ONLINE);

指定者:

bulkUpsert 在接口中 DatabaseProxy

insert

public io.vertx.core.Future<java.lang.Void> insert(java.lang.String traceId,
                                                   java.lang.String table,
                                                   java.util.Map<java.lang.String,java.lang.Object> values)

INSERT INTO DEVICE (DID, TYPE, ONLINE) VALUES ('aaa', 'xxx', 1);

指定者:

insert 在接口中 DatabaseProxy

upsert

public io.vertx.core.Future<java.lang.Void> upsert(java.lang.String traceId,
                                                   java.lang.String table,
                                                   java.lang.String key,
                                                   java.util.Map<java.lang.String,java.lang.Object> values)

INSERT INTO device_summary (did, type, online, accesspoint, bridge, timestamp) VALUES (?, ?, ?, ?, ?, ?) ON DUPLICATE KEY UPDATE type=VALUES(type), online=VALUES(online), accesspoint=VALUES(accesspoint), bridge=VALUES(bridge), timestamp=VALUES(timestamp);

指定者:

upsert 在接口中 DatabaseProxy

delete

public io.vertx.core.Future<java.lang.Void> delete(java.lang.String traceId,
                                                   java.lang.String table)

DELETE FROM DEVICE

指定者:

delete 在接口中 DatabaseProxy

delete

public io.vertx.core.Future<java.lang.Void> delete(java.lang.String traceId,
                                                   java.lang.String table,
                                                   java.lang.String selection,
                                                   java.lang.String[] selectionArgs)

指定者:

delete 在接口中 DatabaseProxy

update

public io.vertx.core.Future<java.lang.Void> update(java.lang.String traceId,
                                                   java.lang.String table,
                                                   java.util.Map<java.lang.String,java.lang.Object> values)

指定者:

update 在接口中 DatabaseProxy

update

public io.vertx.core.Future<java.lang.Void> update(java.lang.String traceId,
                                                   java.lang.String table,
                                                   java.util.Map<java.lang.String,java.lang.Object> values,
                                                   java.lang.String where,
                                                   java.lang.String[] selectionArgs)

指定者:

update 在接口中 DatabaseProxy

count

public io.vertx.core.Future<java.lang.Integer> count(java.lang.String traceId,
                                                     java.lang.String table)

指定者:

count 在接口中 DatabaseProxy

count

public io.vertx.core.Future<java.lang.Integer> count(java.lang.String traceId,
                                                     java.lang.String table,
                                                     java.lang.String selection,
                                                     java.lang.String[] selectionArgs)

指定者:

count 在接口中 DatabaseProxy

close

public io.vertx.core.Future<java.lang.Void> close()

指定者:

close 在接口中 DatabaseProxy