gu.sql2java.manager

类 TableManagers

java.lang.Object

gu.sql2java.manager.TableManagers

public class TableManagers
extends java.lang.Object

TableManager工具类

从以下版本开始:

3.15.4

作者:

guyadong

构造器概要

构造器

构造器和说明
TableManagers()

方法概要

限定符和类型	方法和说明
static <B extends gu.sql2java.BaseBean> java.util.List<gu.sql2java.BaseBean>	aggregateAsList(gu.sql2java.TableManager<B> manager, java.lang.String columns, java.lang.String where, java.lang.String groupBy, java.lang.String having, java.lang.String orderBy, java.lang.Object... argList) 聚合(统计)查询
static java.util.concurrent.ExecutorService	getExecutorService() 返回线程池对象
static <B extends gu.sql2java.BaseBean,T> void	loadByJoinWhereAsync(gu.sql2java.TableManager<B> manager, java.lang.String join, java.lang.String where, java.lang.Object[] argList, int[] fieldList, int numRows, java.util.concurrent.BlockingQueue<T> queue, int queueTimeout, java.util.concurrent.atomic.AtomicBoolean stopped, com.google.common.base.Function<B,T> transformer, java.util.concurrent.Executor executor) 基于QueueProducerAction异步执行 TableManager.loadByJoinWhereForAction(String, String, Object[], int[], int, int, gu.sql2java.TableManager.Action), 查询的数据记录输出到阻塞队列BlockingQueue, 与loadByJoinWhereAsync(TableManager, String, String, Object[], int[], int, int, int, AtomicBoolean, Function, Executor)不同是阻塞队列由调用层提供， 基于此创建QueueProducerAction实例
static <B extends gu.sql2java.BaseBean,T> java.util.concurrent.BlockingQueue<T>	loadByJoinWhereAsync(gu.sql2java.TableManager<B> manager, java.lang.String join, java.lang.String where, java.lang.Object[] argList, int[] fieldList, int numRows, int queueCapacity, int queueTimeout, java.util.concurrent.atomic.AtomicBoolean stopped, com.google.common.base.Function<B,T> transformer, java.util.concurrent.Executor executor) 基于QueueProducerAction异步执行TableManager.loadByJoinWhereForAction(String, String, Object[], int[], int, int, gu.sql2java.TableManager.Action), 查询的数据记录输出到阻塞队列BlockingQueue, 与loadByJoinWhereAsync(TableManager, String, String, Object[], int[], int, BlockingQueue, int, AtomicBoolean, Function, Executor)不同的是 阻塞队列BlockingQueue根据输入参数创建
static <B extends gu.sql2java.BaseBean> void	loadByJoinWhereAsync(gu.sql2java.TableManager<B> manager, java.lang.String join, java.lang.String where, java.lang.Object[] argList, int[] fieldList, int numRows, gu.sql2java.TableManager.Action<B> action, java.util.concurrent.atomic.AtomicBoolean stopped, java.util.concurrent.Executor executor) 基于QueueProducerAction异步执行TableManager.loadByJoinWhereForAction(String, String, Object[], int[], int, int, gu.sql2java.TableManager.Action), 查询的数据记录输出到阻塞队列BlockingQueue
static <B extends gu.sql2java.BaseBean> java.util.concurrent.BlockingQueue<B>	loadByJoinWhereAsync(gu.sql2java.TableManager<B> manager, java.lang.String join, java.lang.String where, java.lang.Object[] argList, int numRows, int queueCapacity, int queueTimeout, java.util.concurrent.atomic.AtomicBoolean stopped, java.util.concurrent.Executor executor) loadByJoinWhereAsync(TableManager, String, String, Object[], int[], int, BlockingQueue, int, AtomicBoolean, Function, Executor)的简化版， 返回队列类型为原始数据库对象类型
static void	setDebug(java.lang.Boolean debug)
static <B extends gu.sql2java.BaseRow> void	updatePk(java.lang.String alias, B bean, java.lang.Object to) 更新记录主键(适用只有一个主键的表)
static <B extends gu.sql2java.BaseRow> void	updatePk(java.lang.String alias, B bean, java.lang.Object[] to) 更新记录主键(适用只有一个主键的表)
static void	updatePk(java.lang.String alias, java.lang.String tablename, java.lang.Object[] from, java.lang.Object[] to) 更新记录主键
static void	updatePk(java.lang.String alias, java.lang.String tablename, java.lang.Object from, java.lang.Object to) 更新记录主键(适用只有一个主键的表)

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

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

构造器详细资料

TableManagers

public TableManagers()

方法详细资料

setDebug

public static void setDebug(java.lang.Boolean debug)

getExecutorService

public static java.util.concurrent.ExecutorService getExecutorService()

返回线程池对象

loadByJoinWhereAsync

public static <B extends gu.sql2java.BaseBean> void loadByJoinWhereAsync(gu.sql2java.TableManager<B> manager,
                                                                         java.lang.String join,
                                                                         java.lang.String where,
                                                                         java.lang.Object[] argList,
                                                                         int[] fieldList,
                                                                         int numRows,
                                                                         gu.sql2java.TableManager.Action<B> action,
                                                                         java.util.concurrent.atomic.AtomicBoolean stopped,
                                                                         java.util.concurrent.Executor executor)

基于QueueProducerAction异步执行TableManager.loadByJoinWhereForAction(String, String, Object[], int[], int, int, gu.sql2java.TableManager.Action), 查询的数据记录输出到阻塞队列BlockingQueue

参数:

manager -

join - JOIN查询参数

where - WHERE查询参数

argList - the arguments to use fill given prepared statement,may be null

fieldList - table of the field's associated constants

numRows - 每次查询返回的记录条数

action -

stopped - 停止标志,为null忽略,为true时结束循环

executor - 异步执行对象,为null则使用默认线程池对象TableManagers.Singleton.GLOBAL_EXECUTOR

另请参阅:

BaseTableManager.loadByJoinWhereForAction(String, String, Object[], int[], int, int, gu.sql2java.TableManager.Action)

loadByJoinWhereAsync

public static <B extends gu.sql2java.BaseBean,T> void loadByJoinWhereAsync(gu.sql2java.TableManager<B> manager,
                                                                           java.lang.String join,
                                                                           java.lang.String where,
                                                                           java.lang.Object[] argList,
                                                                           int[] fieldList,
                                                                           int numRows,
                                                                           java.util.concurrent.BlockingQueue<T> queue,
                                                                           int queueTimeout,
                                                                           java.util.concurrent.atomic.AtomicBoolean stopped,
                                                                           com.google.common.base.Function<B,T> transformer,
                                                                           java.util.concurrent.Executor executor)

基于QueueProducerAction异步执行 TableManager.loadByJoinWhereForAction(String, String, Object[], int[], int, int, gu.sql2java.TableManager.Action), 查询的数据记录输出到阻塞队列BlockingQueue, 与loadByJoinWhereAsync(TableManager, String, String, Object[], int[], int, int, int, AtomicBoolean, Function, Executor)不同是阻塞队列由调用层提供， 基于此创建QueueProducerAction实例

参数:

manager -

join - 查询参数

where - 查询参数

argList - the arguments to use fill given prepared statement,may be null

fieldList - table of the field's associated constants

numRows - 每次查询返回的记录条数

queue - QueueProducerAction构造方法参数，参见 QueueProducerAction.QueueProducerAction(int, int, Function)

queueTimeout - QueueProducerAction构造方法参数，参见 QueueProducerAction.QueueProducerAction(int, int, Function)

stopped - 停止标志,为null忽略,为true时结束循环

transformer - QueueProducerAction构造方法参数，参见 QueueProducerAction.QueueProducerAction(int, int, Function)

executor - 异步执行对象,为null则使用默认线程池对象TableManagers.Singleton.GLOBAL_EXECUTOR

另请参阅:

loadByJoinWhereAsync(TableManager, String, String, Object[], int[], int, gu.sql2java.TableManager.Action, AtomicBoolean, Executor)

loadByJoinWhereAsync

public static <B extends gu.sql2java.BaseBean,T> java.util.concurrent.BlockingQueue<T> loadByJoinWhereAsync(gu.sql2java.TableManager<B> manager,
                                                                                                            java.lang.String join,
                                                                                                            java.lang.String where,
                                                                                                            java.lang.Object[] argList,
                                                                                                            int[] fieldList,
                                                                                                            int numRows,
                                                                                                            int queueCapacity,
                                                                                                            int queueTimeout,
                                                                                                            java.util.concurrent.atomic.AtomicBoolean stopped,
                                                                                                            com.google.common.base.Function<B,T> transformer,
                                                                                                            java.util.concurrent.Executor executor)

基于QueueProducerAction异步执行TableManager.loadByJoinWhereForAction(String, String, Object[], int[], int, int, gu.sql2java.TableManager.Action), 查询的数据记录输出到阻塞队列BlockingQueue, 与loadByJoinWhereAsync(TableManager, String, String, Object[], int[], int, BlockingQueue, int, AtomicBoolean, Function, Executor)不同的是 阻塞队列BlockingQueue根据输入参数创建

参数:

manager -

join - 查询参数

where - 查询参数

argList - the arguments to use fill given prepared statement,may be null

fieldList - table of the field's associated constants

numRows - 每次查询返回的记录条数

queueCapacity - QueueProducerAction构造方法参数，参见 QueueProducerAction.QueueProducerAction(int, int, Function)

queueTimeout - QueueProducerAction构造方法参数，参见 QueueProducerAction.QueueProducerAction(int, int, Function)

stopped - 停止标志,为null忽略,为true时结束循环

transformer - QueueProducerAction构造方法参数，参见 QueueProducerAction.QueueProducerAction(int, int, Function)

executor - 异步执行对象,为null则使用默认线程池对象TableManagers.Singleton.GLOBAL_EXECUTOR

返回:

创建的阻塞队列

另请参阅:

loadByJoinWhereAsync(TableManager, String, String, Object[], int[], int, BlockingQueue, int, AtomicBoolean, Function, Executor)

loadByJoinWhereAsync

public static <B extends gu.sql2java.BaseBean> java.util.concurrent.BlockingQueue<B> loadByJoinWhereAsync(gu.sql2java.TableManager<B> manager,
                                                                                                          java.lang.String join,
                                                                                                          java.lang.String where,
                                                                                                          java.lang.Object[] argList,
                                                                                                          int numRows,
                                                                                                          int queueCapacity,
                                                                                                          int queueTimeout,
                                                                                                          java.util.concurrent.atomic.AtomicBoolean stopped,
                                                                                                          java.util.concurrent.Executor executor)

loadByJoinWhereAsync(TableManager, String, String, Object[], int[], int, BlockingQueue, int, AtomicBoolean, Function, Executor)的简化版， 返回队列类型为原始数据库对象类型

另请参阅:

loadByJoinWhereAsync(TableManager, String, String, Object[], int[], int, BlockingQueue, int, AtomicBoolean, Function, Executor)

aggregateAsList

public static <B extends gu.sql2java.BaseBean> java.util.List<gu.sql2java.BaseBean> aggregateAsList(gu.sql2java.TableManager<B> manager,
                                                                                                    java.lang.String columns,
                                                                                                    java.lang.String where,
                                                                                                    java.lang.String groupBy,
                                                                                                    java.lang.String having,
                                                                                                    java.lang.String orderBy,
                                                                                                    java.lang.Object... argList)

聚合(统计)查询

参数:

manager -

columns - SELECT 语句字段输出表达式列表部分

where - SELECT 语句 WHERE条件e表达式部分,为null忽略

groupBy - 聚合查询字段名列表

having - HAVING 表达式,为null忽略

orderBy - 排序表达式(ORDER BY起始),为null忽略

argList - SQL语句中的参数列表

返回:

聚合查询结果

updatePk

public static void updatePk(java.lang.String alias,
                            java.lang.String tablename,
                            java.lang.Object[] from,
                            java.lang.Object[] to)

更新记录主键

参数:

alias -

tablename -

from -

to -

从以下版本开始:

3.30.0

updatePk

public static void updatePk(java.lang.String alias,
                            java.lang.String tablename,
                            java.lang.Object from,
                            java.lang.Object to)

更新记录主键(适用只有一个主键的表)

参数:

alias -

tablename -

from -

to -

从以下版本开始:

3.30.0

updatePk

public static <B extends gu.sql2java.BaseRow> void updatePk(java.lang.String alias,
                                                            B bean,
                                                            java.lang.Object[] to)

更新记录主键(适用只有一个主键的表)

参数:

alias -

bean -

to -

从以下版本开始:

3.30.0

updatePk

public static <B extends gu.sql2java.BaseRow> void updatePk(java.lang.String alias,
                                                            B bean,
                                                            java.lang.Object to)

更新记录主键(适用只有一个主键的表)

参数:

alias -

bean -

to -

从以下版本开始:

3.30.0