xyz.noark.orm.accessor.sql

类 AbstractSqlDataAccessor

java.lang.Object

xyz.noark.orm.accessor.AbstractDataAccessor

xyz.noark.orm.accessor.sql.AbstractSqlDataAccessor

所有已实现的接口:

DataAccessor

直接已知子类:

MysqlDataAccessor

public abstract class AbstractSqlDataAccessor
extends AbstractDataAccessor

SQL存储策略入口.

从以下版本开始:

3.0

作者:

小流氓[176543888@qq.com]

字段概要

字段

限定符和类型	字段和说明
protected boolean	autoAlterColumnLength 服务器数据是否智能修正文本字段的长度，默认：true
protected boolean	autoAlterEmojiColumn 服务器数据是否智能转化EMOJI的字段，默认：true
protected javax.sql.DataSource	dataSource
protected SqlExpert	expert
protected int	slowQuerySqlMillis 慢查询时间阀值(单位：毫秒),如果为0则不监控
protected boolean	statementExecutableSqlLogEnable 是否输出执行SQL日志
protected boolean	statementParameterSetLogEnable 是否输出执行SQL的参数日志(上一个必需要true)

构造器概要

构造器

构造器和说明
AbstractSqlDataAccessor(SqlExpert expert, javax.sql.DataSource dataSource)

方法概要

限定符和类型	方法和说明
protected <T> void	autoAlterTableUpdateColumn(EntityMapping<T> em, FieldMapping fm) 自动修正字段
<T> void	checkupEntityFieldsWithDatabase(EntityMapping<T> em) 检查一下表结构是不是跟这个实体一样一样的.
protected <T> T	execute(EntityMapping<?> em, PreparedStatementCallback<T> action, java.lang.String sql, boolean flag) 执行SQL的逻辑，只能是异常显示数据.
protected <T> T	executeBatch(EntityMapping<?> em, PreparedStatementCallback<T> action, java.lang.String sql, boolean flag)
protected <T> T	executeStatement(StatementCallback<T> action)
protected boolean	exists(java.lang.String tableName) 判定一个表是否存在.
protected abstract void	handleDataTooLongException(EntityMapping<?> em, java.util.Map<java.lang.String,java.lang.Integer> columnMaxLenMap) 处理数据过长的异常情况
void	judgeAccessType() 猜测一下用的DB信息
void	setAutoAlterTableDropColumn(boolean autoAlterTableDropColumn)
void	setSlowQuerySqlMillis(int slowQuerySqlMillis)
void	setStatementExecutableSqlLogEnable(boolean statementExecutableSqlLogEnable)
void	setStatementParameterSetLogEnable(boolean statementParameterSetLogEnable)

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

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

从接口继承的方法 xyz.noark.orm.accessor.DataAccessor

batchDelete, batchInsert, batchUpdate, delete, insert, load, loadAll, loadAll, update

字段详细资料

expert

protected final SqlExpert expert

dataSource

protected final javax.sql.DataSource dataSource

statementExecutableSqlLogEnable

@Value(value="data.sql.log.enable")
protected boolean statementExecutableSqlLogEnable

是否输出执行SQL日志

statementParameterSetLogEnable

@Value(value="data.sql.log.parameter.enable")
protected boolean statementParameterSetLogEnable

是否输出执行SQL的参数日志(上一个必需要true)

slowQuerySqlMillis

@Value(value="data.slow.query.sql.millis")
protected int slowQuerySqlMillis

慢查询时间阀值(单位：毫秒),如果为0则不监控

autoAlterColumnLength

@Value(value="data.auto.alter.column.length")
protected boolean autoAlterColumnLength

服务器数据是否智能修正文本字段的长度，默认：true

autoAlterEmojiColumn

@Value(value="data.auto.alter.emoji.column")
protected boolean autoAlterEmojiColumn

服务器数据是否智能转化EMOJI的字段，默认：true

构造器详细资料

AbstractSqlDataAccessor

public AbstractSqlDataAccessor(SqlExpert expert,
                               javax.sql.DataSource dataSource)

方法详细资料

judgeAccessType

public void judgeAccessType()

从接口复制的说明: DataAccessor

猜测一下用的DB信息

setStatementExecutableSqlLogEnable

public void setStatementExecutableSqlLogEnable(boolean statementExecutableSqlLogEnable)

setStatementParameterSetLogEnable

public void setStatementParameterSetLogEnable(boolean statementParameterSetLogEnable)

setSlowQuerySqlMillis

public void setSlowQuerySqlMillis(int slowQuerySqlMillis)

setAutoAlterTableDropColumn

public void setAutoAlterTableDropColumn(boolean autoAlterTableDropColumn)

executeStatement

protected <T> T executeStatement(StatementCallback<T> action)

execute

protected <T> T execute(EntityMapping<?> em,
                        PreparedStatementCallback<T> action,
                        java.lang.String sql,
                        boolean flag)

执行SQL的逻辑，只能是异常显示数据.

类型参数:

T - 数据类型

参数:

em - 实体对象描述

action - PreparedStatement回调接口

sql - 执行SQL

flag - 如果遇到数据长度异常情况，是否自动扩容

返回:

执行结果

executeBatch

protected <T> T executeBatch(EntityMapping<?> em,
                             PreparedStatementCallback<T> action,
                             java.lang.String sql,
                             boolean flag)

handleDataTooLongException

protected abstract void handleDataTooLongException(EntityMapping<?> em,
                                                   java.util.Map<java.lang.String,java.lang.Integer> columnMaxLenMap)

处理数据过长的异常情况

参数:

em - 实体对象描述

columnMaxLenMap - 每个字段目前已用的最大长记录

exists

protected boolean exists(java.lang.String tableName)

判定一个表是否存在.

参数:

tableName - 表名

返回:

如果存在返回true, 否则返回false

checkupEntityFieldsWithDatabase

public <T> void checkupEntityFieldsWithDatabase(EntityMapping<T> em)

检查一下表结构是不是跟这个实体一样一样的.

指定者:

checkupEntityFieldsWithDatabase 在接口中 DataAccessor

覆盖:

checkupEntityFieldsWithDatabase 在类中 AbstractDataAccessor

类型参数:

T - 实体对象类型

参数:

em - 对象实体描述类.

autoAlterTableUpdateColumn

protected <T> void autoAlterTableUpdateColumn(EntityMapping<T> em,
                                              FieldMapping fm)

自动修正字段

类型参数:

T - 实体类型

参数:

em - 实体描述对象

fm - 实体指定属性描述对象