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

Class DatabaseProxyJdbcImpl

java.lang.Object

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

All Implemented Interfaces:

DatabaseProxy

public class DatabaseProxyJdbcImpl
extends java.lang.Object
implements DatabaseProxy

Constructor Summary

Constructors

Constructor and Description
DatabaseProxyJdbcImpl(io.vertx.core.Vertx vertx, io.vertx.core.json.JsonObject config)

Method Summary

Modifier and Type	Method and Description
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 (?, ?, ?, ?, ?, ?) ON DUPLICATE KEY UPDATE type=VALUES(type), online=VALUES(online), accesspoint=VALUES(accesspoint), bridge=VALUES(bridge), timestamp=VALUES(timestamp);

Methods inherited from class java.lang.Object

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

Methods inherited from interface cn.geekcity.xiot.support.vertx.database.proxy.DatabaseProxy

create

Constructor Detail

DatabaseProxyJdbcImpl

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

Method Detail

exists

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

Specified by:

exists in interface DatabaseProxy

execSQL

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

Specified by:

execSQL in interface 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)

Specified by:

rawQuery in interface 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)

Specified by:

rawQueryOne in interface 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;

Specified by:

query in interface 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)

Specified by:

query in interface 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)

Specified by:

queryOne in interface 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);

Specified by:

bulkInsert in interface 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);

Specified by:

bulkUpsert in interface 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);

Specified by:

insert in interface 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);

Specified by:

upsert in interface DatabaseProxy

delete

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

DELETE FROM DEVICE

Specified by:

delete in interface 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)

Specified by:

delete in interface 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)

Specified by:

update in interface 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)

Specified by:

update in interface DatabaseProxy

count

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

Specified by:

count in interface 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)

Specified by:

count in interface DatabaseProxy

close

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

Specified by:

close in interface DatabaseProxy