Package cc.carm.lib.easysql.manager

Class SQLManagerImpl

java.lang.Object

cc.carm.lib.easysql.manager.SQLManagerImpl

All Implemented Interfaces:

SQLManager

public class SQLManagerImpl
extends java.lang.Object
implements SQLManager

Field Summary

Fields

Modifier and Type	Field	Description
protected java.util.concurrent.ExecutorService	executorPool

Constructor Summary

Constructors

Constructor	Description
SQLManagerImpl(@NotNull javax.sql.DataSource dataSource)
SQLManagerImpl(@NotNull javax.sql.DataSource dataSource, @NotNull org.slf4j.Logger logger, @Nullable java.lang.String name)
SQLManagerImpl(@NotNull javax.sql.DataSource dataSource, @Nullable java.lang.String name)

Method Summary

Modifier and Type	Method	Description
TableAlterBuilder	alterTable(@NotNull java.lang.String tableName)	对库中的某个表执行更改
DeleteBuilder	createDelete(@NotNull java.lang.String tableName)	创建删除操作
InsertBuilder<PreparedSQLUpdateAction<java.lang.Integer>>	createInsert(@NotNull java.lang.String tableName)	创建一条插入操作
InsertBuilder<PreparedSQLUpdateBatchAction<java.lang.Integer>>	createInsertBatch(@NotNull java.lang.String tableName)	创建支持多组数据的插入操作
QueryBuilder	createQuery()	新建一个查询
ReplaceBuilder<PreparedSQLUpdateAction<java.lang.Integer>>	createReplace(@NotNull java.lang.String tableName)	创建一条替换操作
ReplaceBuilder<PreparedSQLUpdateBatchAction<java.lang.Integer>>	createReplaceBatch(@NotNull java.lang.String tableName)	创建支持多组数据的替换操作
TableCreateBuilder	createTable(@NotNull java.lang.String tableName)	在库中创建一个表
UpdateBuilder	createUpdate(@NotNull java.lang.String tableName)	创建更新操作
void	debug(java.lang.String msg)
java.lang.Integer	executeSQL(java.lang.String sql)	执行一条不需要返回结果的SQL语句(多用于UPDATE、REPLACE、DELETE方法) 该方法使用 Statement 实现，请注意SQL注入风险！
java.lang.Integer	executeSQL(java.lang.String sql, java.lang.Object[] params)	执行一条不需要返回结果的预处理SQL更改(UPDATE、REPLACE、DELETE)
@Nullable java.util.List<java.lang.Integer>	executeSQLBatch(@NotNull java.lang.Iterable<java.lang.String> sqlBatch)	执行多条不需要返回结果的SQL。
java.util.List<java.lang.Integer>	executeSQLBatch(@NotNull java.lang.String sql, java.lang.String... moreSQL)	执行多条不需要返回结果的SQL。
java.util.List<java.lang.Integer>	executeSQLBatch(java.lang.String sql, java.lang.Iterable<java.lang.Object[]> paramsBatch)	执行多条不需要返回结果的SQL更改(UPDATE、REPLACE、DELETE)
@NotNull java.util.Map<java.util.UUID,SQLQuery>	getActiveQuery()	得到正使用的查询。
@NotNull java.sql.Connection	getConnection()	得到一个数据库连接实例
@NotNull javax.sql.DataSource	getDataSource()	得到连接池源
@NotNull SQLDebugHandler	getDebugHandler()	获取调试处理器，用于处理调试信息。
@NotNull SQLExceptionHandler	getExceptionHandler()	获取改管理器提供的默认异常处理器。
@NotNull java.util.concurrent.ExecutorService	getExecutorPool()	获取用于执行 SQLAction.executeAsync() 的线程池。
org.slf4j.Logger	getLogger()
boolean	isDebugMode()
void	setDebugHandler(@NotNull SQLDebugHandler debugHandler)	设定调试处理器，默认为 SQLDebugHandler.defaultHandler(Logger) 。
void	setDebugMode(@NotNull java.util.function.Supplier<@NotNull java.lang.Boolean> debugMode)	设定是否启用调试模式。
void	setExceptionHandler(@Nullable SQLExceptionHandler handler)	设定通用的异常处理器。
void	setExecutorPool(@NotNull java.util.concurrent.ExecutorService executorPool)	设定用于执行 SQLAction.executeAsync() 的线程池。

Methods inherited from class java.lang.Object

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

Methods inherited from interface cc.carm.lib.easysql.api.SQLManager

setDebugMode

Field Detail

executorPool

protected java.util.concurrent.ExecutorService executorPool

Constructor Detail

SQLManagerImpl

public SQLManagerImpl(@NotNull
                      @NotNull javax.sql.DataSource dataSource)

SQLManagerImpl

public SQLManagerImpl(@NotNull
                      @NotNull javax.sql.DataSource dataSource,
                      @Nullable
                      @Nullable java.lang.String name)

SQLManagerImpl

public SQLManagerImpl(@NotNull
                      @NotNull javax.sql.DataSource dataSource,
                      @NotNull
                      @NotNull org.slf4j.Logger logger,
                      @Nullable
                      @Nullable java.lang.String name)

Method Detail

isDebugMode

public boolean isDebugMode()

Specified by:

isDebugMode in interface SQLManager

setDebugMode

public void setDebugMode(@NotNull
                         @NotNull java.util.function.Supplier<@NotNull java.lang.Boolean> debugMode)

Description copied from interface: SQLManager

设定是否启用调试模式。 启用调试模式后，会在每次执行SQL语句时，调用 SQLManager.getDebugHandler() 来输出调试信息。

Specified by:

setDebugMode in interface SQLManager

Parameters:

debugMode - 是否启用调试模式

getDebugHandler

@NotNull
public @NotNull SQLDebugHandler getDebugHandler()

Description copied from interface: SQLManager

获取调试处理器，用于处理调试信息。

Specified by:

getDebugHandler in interface SQLManager

Returns:

SQLDebugHandler

setDebugHandler

public void setDebugHandler(@NotNull
                            @NotNull SQLDebugHandler debugHandler)

Description copied from interface: SQLManager

设定调试处理器，默认为 SQLDebugHandler.defaultHandler(Logger) 。

Specified by:

setDebugHandler in interface SQLManager

Parameters:

debugHandler - SQLDebugHandler

debug

public void debug(java.lang.String msg)

getLogger

public org.slf4j.Logger getLogger()

Specified by:

getLogger in interface SQLManager

getExecutorPool

@NotNull
public @NotNull java.util.concurrent.ExecutorService getExecutorPool()

Description copied from interface: SQLManager

获取用于执行 SQLAction.executeAsync() 的线程池。
默认线程池为 ThreadPoolExecutor ,大小为 3。

Specified by:

getExecutorPool in interface SQLManager

Returns:

ExecutorService

setExecutorPool

public void setExecutorPool(@NotNull
                            @NotNull java.util.concurrent.ExecutorService executorPool)

Description copied from interface: SQLManager

设定用于执行 SQLAction.executeAsync() 的线程池。

Specified by:

setExecutorPool in interface SQLManager

Parameters:

executorPool - ExecutorService

getDataSource

@NotNull
public @NotNull javax.sql.DataSource getDataSource()

Description copied from interface: SQLManager

得到连接池源

Specified by:

getDataSource in interface SQLManager

Returns:

DataSource

getConnection

@NotNull
public @NotNull java.sql.Connection getConnection()
                                           throws java.sql.SQLException

Description copied from interface: SQLManager

得到一个数据库连接实例

Specified by:

getConnection in interface SQLManager

Returns:

Connection

Throws:

java.sql.SQLException - 见 DataSource.getConnection()

getActiveQuery

@NotNull
public @NotNull java.util.Map<java.util.UUID,SQLQuery> getActiveQuery()

Description copied from interface: SQLManager

得到正使用的查询。

Specified by:

getActiveQuery in interface SQLManager

Returns:

查询列表

getExceptionHandler

@NotNull
public @NotNull SQLExceptionHandler getExceptionHandler()

Description copied from interface: SQLManager

获取改管理器提供的默认异常处理器。 若未使用过 SQLManager.setExceptionHandler(SQLExceptionHandler) 方法， 则默认返回 SQLExceptionHandler.detailed(Logger) 。

Specified by:

getExceptionHandler in interface SQLManager

Returns:

SQLExceptionHandler

setExceptionHandler

public void setExceptionHandler(@Nullable
                                @Nullable SQLExceptionHandler handler)

Description copied from interface: SQLManager

设定通用的异常处理器。
在使用 SQLAction.execute(SQLExceptionHandler) 等相关方法时，若传入的处理器为null，则会采用此处理器。
若该方法传入参数为 null，则会使用 SQLExceptionHandler.detailed(Logger) 。

Specified by:

setExceptionHandler in interface SQLManager

Parameters:

handler - 异常处理器

executeSQL

public java.lang.Integer executeSQL(java.lang.String sql)

Description copied from interface: SQLManager

执行一条不需要返回结果的SQL语句(多用于UPDATE、REPLACE、DELETE方法) 该方法使用 Statement 实现，请注意SQL注入风险！

Specified by:

executeSQL in interface SQLManager

Parameters:

sql - SQL语句内容

Returns:

更新的行数

See Also:

SQLUpdateAction

executeSQL

public java.lang.Integer executeSQL(java.lang.String sql,
                                    java.lang.Object[] params)

Description copied from interface: SQLManager

执行一条不需要返回结果的预处理SQL更改(UPDATE、REPLACE、DELETE)

Specified by:

executeSQL in interface SQLManager

Parameters:

sql - SQL语句内容

params - SQL语句中 ? 的对应参数

Returns:

更新的行数

See Also:

PreparedSQLUpdateAction

executeSQLBatch

public java.util.List<java.lang.Integer> executeSQLBatch(java.lang.String sql,
                                                         java.lang.Iterable<java.lang.Object[]> paramsBatch)

Description copied from interface: SQLManager

执行多条不需要返回结果的SQL更改(UPDATE、REPLACE、DELETE)

Specified by:

executeSQLBatch in interface SQLManager

Parameters:

sql - SQL语句内容

paramsBatch - SQL语句中对应?的参数组

Returns:

对应参数返回的行数

See Also:

PreparedSQLUpdateBatchAction

executeSQLBatch

public java.util.List<java.lang.Integer> executeSQLBatch(@NotNull
                                                         @NotNull java.lang.String sql,
                                                         java.lang.String... moreSQL)

Description copied from interface: SQLManager

执行多条不需要返回结果的SQL。 该方法使用 Statement 实现，请注意SQL注入风险！

Specified by:

executeSQLBatch in interface SQLManager

Parameters:

sql - SQL语句内容

moreSQL - 更多SQL语句内容

Returns:

对应参数返回的行数

See Also:

SQLUpdateBatchAction

executeSQLBatch

@Nullable
public @Nullable java.util.List<java.lang.Integer> executeSQLBatch(@NotNull
                                                                   @NotNull java.lang.Iterable<java.lang.String> sqlBatch)

Description copied from interface: SQLManager

执行多条不需要返回结果的SQL。

Specified by:

executeSQLBatch in interface SQLManager

Parameters:

sqlBatch - SQL语句内容

Returns:

对应参数返回的行数

createTable

public TableCreateBuilder createTable(@NotNull
                                      @NotNull java.lang.String tableName)

Description copied from interface: SQLManager

在库中创建一个表

Specified by:

createTable in interface SQLManager

Parameters:

tableName - 表名

Returns:

TableCreateBuilder

alterTable

public TableAlterBuilder alterTable(@NotNull
                                    @NotNull java.lang.String tableName)

Description copied from interface: SQLManager

对库中的某个表执行更改

Specified by:

alterTable in interface SQLManager

Parameters:

tableName - 表名

Returns:

TableAlterBuilder

createQuery

public QueryBuilder createQuery()

Description copied from interface: SQLManager

新建一个查询

Specified by:

createQuery in interface SQLManager

Returns:

QueryBuilder

createInsertBatch

public InsertBuilder<PreparedSQLUpdateBatchAction<java.lang.Integer>> createInsertBatch(@NotNull
                                                                                        @NotNull java.lang.String tableName)

Description copied from interface: SQLManager

创建支持多组数据的插入操作

Specified by:

createInsertBatch in interface SQLManager

Parameters:

tableName - 目标表名

Returns:

InsertBuilder

createInsert

public InsertBuilder<PreparedSQLUpdateAction<java.lang.Integer>> createInsert(@NotNull
                                                                              @NotNull java.lang.String tableName)

Description copied from interface: SQLManager

创建一条插入操作

Specified by:

createInsert in interface SQLManager

Parameters:

tableName - 目标表名

Returns:

InsertBuilder

createReplaceBatch

public ReplaceBuilder<PreparedSQLUpdateBatchAction<java.lang.Integer>> createReplaceBatch(@NotNull
                                                                                          @NotNull java.lang.String tableName)

Description copied from interface: SQLManager

创建支持多组数据的替换操作

Specified by:

createReplaceBatch in interface SQLManager

Parameters:

tableName - 目标表名

Returns:

ReplaceBuilder

createReplace

public ReplaceBuilder<PreparedSQLUpdateAction<java.lang.Integer>> createReplace(@NotNull
                                                                                @NotNull java.lang.String tableName)

Description copied from interface: SQLManager

创建一条替换操作

Specified by:

createReplace in interface SQLManager

Parameters:

tableName - 目标表名

Returns:

ReplaceBuilder

createUpdate

public UpdateBuilder createUpdate(@NotNull
                                  @NotNull java.lang.String tableName)

Description copied from interface: SQLManager

创建更新操作

Specified by:

createUpdate in interface SQLManager

Parameters:

tableName - 目标表名

Returns:

UpdateBuilder

createDelete

public DeleteBuilder createDelete(@NotNull
                                  @NotNull java.lang.String tableName)

Description copied from interface: SQLManager

创建删除操作

Specified by:

createDelete in interface SQLManager

Parameters:

tableName - 目标表名

Returns:

DeleteBuilder