com.kdayun.manager.service.impl

类 CoreTablesServiceImpl

java.lang.Object

com.kdayun.z1.core.base.BaseServiceImpl<CoreTables>

com.kdayun.manager.service.impl.CoreTablesServiceImpl

所有已实现的接口:

CoreTablesService, BaseService<CoreTables>

@CacheConfig(cacheNames="tableCache")
 @Transactional(rollbackFor=java.lang.Exception.class)
 @Service
public class CoreTablesServiceImpl
extends BaseServiceImpl<CoreTables>
implements CoreTablesService

表模型实现类

作者:

gk

date:

2018年9月25日 下午5:45:02

嵌套类概要

嵌套类

限定符和类型	类和说明
class	CoreTablesServiceImpl.ListComparator

字段概要

字段

限定符和类型	字段和说明
(专用程序包) java.util.List<java.lang.String>	baseModel
(专用程序包) static java.lang.String	CORE_DEFAULT_COLUMNS
(专用程序包) static java.lang.String	CORE_DEFAULT_TREE_COLUMNS
(专用程序包) CoreDbService	coreDbService
(专用程序包) CoreDictionaryMapper	coreDictionaryMapper
(专用程序包) CoreTablesColumnMapper	coreTablesColumnMapper
(专用程序包) CoreTablesColumnService	coreTablesColumnService
(专用程序包) CoreTablesIndexMapper	coreTablesIndexMapper
(专用程序包) CoreTablesIndexService	coreTablesIndexService
(专用程序包) CoreTablesLinkMapper	coreTablesLinkMapper
(专用程序包) CoreTablesLinkService	coreTablesLinkService
(专用程序包) CoreTablesMapper	coreTablesMapper
static java.lang.String	EXP_DBALLMODEL_FILENAME
static java.lang.String	EXP_MODEL_EXI
static java.lang.String	INIT_FILENAME
static java.lang.String	INIT_MAIN_FILE
static java.lang.String	INIT_MODEL_MAIN_EXI
static java.lang.String	INIT_SYS_VERSION_RWID
(专用程序包) static java.lang.String	MSG_FORMAT 消息格式
(专用程序包) static java.lang.String	PROCESS_FORMAT 进度格式
(专用程序包) static java.util.List<java.lang.String>	SORT_LIST 初始化的排序列表 按顺序优先级
(专用程序包) CoreSqlBuilderServiceImpl	sqlBuilderService
(专用程序包) SqlExecutor	sqlExecutor

构造器概要

构造器

构造器和说明
CoreTablesServiceImpl()

方法概要

限定符和类型	方法和说明
CoreTables	addEntity(CoreTables entity) 新增实体并返回实体
boolean	checkTableDataFilterCnd(java.lang.String rwid, java.lang.String condition) 校验数据过滤条件
void	DragTable(CoreTables coreTables) 表拖拽
java.io.File	exportDb2ModelZip(java.lang.String outPutDir, java.lang.String condition) 导出数据库的所有表成模型 zip文件 如果同时存在的物料表列与模型列会把模型的列信息带优先取出
java.io.File	exportModelZip(java.util.List<CoreTables> tbs, java.lang.String outPutDir) 导出模型文件
java.io.File	exportModelZip(java.util.List<CoreTables> tbs, java.lang.String outPutDir, java.lang.String FileName) 导出模型文件
java.io.File	exportModelZip(java.lang.String outPutDir) 根据模型表导出模型zip压缩文件
java.util.List<CoreTables>	findListByTableNames(java.util.List<java.lang.String> namesList) 通过表名查询表模型
java.util.List<CoreTables>	findListExt(java.util.Map<java.lang.String,java.lang.Object> params) 查询扩展，可以查询多个rwid
CoreTables	fromFile(java.lang.String filePath) 从文件反序列化成表模型对象
java.util.Map<java.lang.String,java.net.URL>	getCreatedTablesByModelFile(java.util.List<java.net.URL> urls) 根据模型文件获取已创建的表
CoreTables	getEntity(java.lang.String id) 根据Id获取实体
java.util.List<java.util.LinkedHashMap<java.lang.String,java.lang.Object>>	getTableData(java.lang.String tableName, PageParams page) 获取指定表的数据
java.util.List<java.util.LinkedHashMap<java.lang.String,java.lang.Object>>	getTableDataById(java.lang.String tableName, java.lang.String rwid) 根据主键rwid得到指定表的数据
java.util.List<CoreTables>	getTableModel() 获取表所有对象
java.util.List<CoreTables>	getTableModel(java.lang.String[] tbIds) 获取表对象 根据给定的表rwid集合
java.util.List<CoreTables>	getTableModelAndBigfieldFiles(java.util.List<CoreTables> tbs, java.lang.String bigfieldFileDir) 根据指定的表id集合获取表模型，并将表模型中的大字段数据保存到bigfieldFileDir目录下
java.util.List<CoreTables>	getTableModelFromDbStructure()
void	importModelFile(java.net.URL fileUrl) 导入模型文件
void	importModelZip(java.lang.String zipFileName) 导入模型文件
RetVo	initSystem() 初始化系统
RetVo	initSystem(java.util.List<java.lang.String> modelNames) 初始化系统
java.lang.Boolean	isExistsTableName(java.lang.String tbId, java.lang.String tableName) 查询表名是否存在
java.util.List<CoreTables>	isSyncTableModelToDB(java.util.List<CoreTables> tables) 判断是否表模型是否同步
java.lang.Boolean	isSyncTableModelToDB(java.lang.String tbId) 判断表是否创建且表结构中的列是否都创建
int	modify(CoreTables entity) 更新实体
void	modifyModelType(CoreTables oldTable, CoreTables table) 修改表模型类型
int	modifySysSortValueNotNull() 更新系统排序字段值不为空
CoreTables	modifyToDB(java.lang.String tbId) 更新数据库
int	removeById(java.lang.String id) 删除实体
void	resetDataSource() 读取配置文件 重新启动数据库链接 TO DO 这个函数没作用暂时保留
void	saveJdbc(CoreJdbcVo jdbc) 保存jdbc设置
void	scanModel() * 扫描模型与数据结构的差异，并执行更新 1.数据库不存在表 创建 2.数据库存在表 1）检查字段差异 不存在字段 新增字段 存在字段 比较类型，长度 并尝试修改表结构 （各个数据库的修改限制规则不一，只要没报错误就说明修改成功） 2）记录差异 不存在记录 新增 存在记录 就更新记录
void	setSysInitVersion(java.lang.String version)
void	syncTableModle() 校验数据库模型的与数据库结构完整性

从类继承的方法 com.kdayun.z1.core.base.BaseServiceImpl

add, confirm, findAll, findList, removeByIds, saveJdbc, startProcess, startProcess

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

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

从接口继承的方法 com.kdayun.manager.service.CoreTablesService

saveJdbc

从接口继承的方法 com.kdayun.z1.core.base.BaseService

add, confirm, findAll, findList, removeByIds, startProcess, startProcess

字段详细资料

INIT_FILENAME

public static final java.lang.String INIT_FILENAME

另请参阅:

常量字段值

INIT_MAIN_FILE

public static final java.lang.String INIT_MAIN_FILE

另请参阅:

常量字段值

EXP_DBALLMODEL_FILENAME

public static final java.lang.String EXP_DBALLMODEL_FILENAME

另请参阅:

常量字段值

EXP_MODEL_EXI

public static final java.lang.String EXP_MODEL_EXI

另请参阅:

常量字段值

INIT_MODEL_MAIN_EXI

public static final java.lang.String INIT_MODEL_MAIN_EXI

另请参阅:

常量字段值

coreTablesMapper

@Autowired
CoreTablesMapper coreTablesMapper

coreTablesColumnService

@Autowired
CoreTablesColumnService coreTablesColumnService

coreTablesIndexService

@Autowired
CoreTablesIndexService coreTablesIndexService

coreTablesLinkService

@Autowired
CoreTablesLinkService coreTablesLinkService

coreDictionaryMapper

@Autowired
CoreDictionaryMapper coreDictionaryMapper

coreTablesColumnMapper

@Autowired
CoreTablesColumnMapper coreTablesColumnMapper

coreTablesIndexMapper

@Autowired
CoreTablesIndexMapper coreTablesIndexMapper

coreTablesLinkMapper

@Autowired
CoreTablesLinkMapper coreTablesLinkMapper

coreDbService

@Autowired
CoreDbService coreDbService

sqlBuilderService

@Autowired
CoreSqlBuilderServiceImpl sqlBuilderService

sqlExecutor

@Autowired
SqlExecutor sqlExecutor

CORE_DEFAULT_COLUMNS

static java.lang.String CORE_DEFAULT_COLUMNS

CORE_DEFAULT_TREE_COLUMNS

static java.lang.String CORE_DEFAULT_TREE_COLUMNS

INIT_SYS_VERSION_RWID

public static java.lang.String INIT_SYS_VERSION_RWID

baseModel

java.util.List<java.lang.String> baseModel

SORT_LIST

static final java.util.List<java.lang.String> SORT_LIST

初始化的排序列表 按顺序优先级

MSG_FORMAT

static final java.lang.String MSG_FORMAT

消息格式

另请参阅:

常量字段值

PROCESS_FORMAT

static final java.lang.String PROCESS_FORMAT

进度格式

另请参阅:

常量字段值

构造器详细资料

CoreTablesServiceImpl

public CoreTablesServiceImpl()

方法详细资料

getEntity

@Cacheable(key="#id")
public CoreTables getEntity(java.lang.String id)
                                            throws java.lang.Exception

从接口复制的说明: BaseService

根据Id获取实体

指定者:

getEntity 在接口中 BaseService<CoreTables>

覆盖:

getEntity 在类中 BaseServiceImpl<CoreTables>

参数:

id - 实体id

返回:

实体实例

抛出:

java.lang.Exception - 出错会抛出异常

modify

@CacheEvict(allEntries=true,
            beforeInvocation=true)
public int modify(CoreTables entity)
                                                                             throws java.lang.Exception

从接口复制的说明: BaseService

更新实体

指定者:

modify 在接口中 BaseService<CoreTables>

覆盖:

modify 在类中 BaseServiceImpl<CoreTables>

参数:

entity - 实体对象

返回:

影响的记录数

抛出:

java.lang.Exception - 出错会抛出异常

modifyModelType

public void modifyModelType(CoreTables oldTable,
                            CoreTables table)
                     throws java.lang.Exception

从接口复制的说明: CoreTablesService

修改表模型类型

指定者:

modifyModelType 在接口中 CoreTablesService

参数:

oldTable - 旧表模型实体

table - 新表模型实体

抛出:

java.lang.Exception - 出错会抛出异常

addEntity

public CoreTables addEntity(CoreTables entity)
                     throws java.lang.Exception

从接口复制的说明: BaseService

新增实体并返回实体

指定者:

addEntity 在接口中 BaseService<CoreTables>

覆盖:

addEntity 在类中 BaseServiceImpl<CoreTables>

参数:

entity - 实体对象

返回:

实体实例

抛出:

java.lang.Exception - 出错会抛出异常

removeById

@CacheEvict(allEntries=true,
            beforeInvocation=true)
public int removeById(java.lang.String id)
                                                                                 throws java.lang.Exception

从接口复制的说明: BaseService

删除实体

指定者:

removeById 在接口中 BaseService<CoreTables>

覆盖:

removeById 在类中 BaseServiceImpl<CoreTables>

参数:

id - 实体id

返回:

影响的记录数

抛出:

java.lang.Exception - 出错会抛出异常

modifyToDB

@CacheEvict(allEntries=true,
            beforeInvocation=true)
public CoreTables modifyToDB(java.lang.String tbId)
                                                                                        throws freemarker.template.TemplateNotFoundException,
                                                                                               freemarker.template.MalformedTemplateNameException,
                                                                                               freemarker.core.ParseException,
                                                                                               java.io.IOException,
                                                                                               freemarker.template.TemplateException,
                                                                                               java.sql.SQLException,
                                                                                               java.lang.Exception

从接口复制的说明: CoreTablesService

更新数据库

指定者:

modifyToDB 在接口中 CoreTablesService

参数:

tbId - 表模型的id

返回:

返回更新以后的表对象

抛出:

java.lang.Exception - 出错会抛出异常

freemarker.template.TemplateNotFoundException

freemarker.template.MalformedTemplateNameException

freemarker.core.ParseException

java.io.IOException

freemarker.template.TemplateException

java.sql.SQLException

syncTableModle

public void syncTableModle()

从接口复制的说明: CoreTablesService

校验数据库模型的与数据库结构完整性

指定者:

syncTableModle 在接口中 CoreTablesService

getTableModel

public java.util.List<CoreTables> getTableModel()
                                         throws java.lang.Exception

从接口复制的说明: CoreTablesService

获取表所有对象

指定者:

getTableModel 在接口中 CoreTablesService

返回:

表模型 list

抛出:

java.lang.Exception - 出错会抛出异常

getTableModel

public java.util.List<CoreTables> getTableModel(java.lang.String[] tbIds)
                                         throws java.lang.Exception

从接口复制的说明: CoreTablesService

获取表对象 根据给定的表rwid集合

指定者:

getTableModel 在接口中 CoreTablesService

参数:

tbIds - 表rwid集合

返回:

表模型 list

抛出:

java.lang.Exception - 出错会抛出异常

getTableModelAndBigfieldFiles

public java.util.List<CoreTables> getTableModelAndBigfieldFiles(java.util.List<CoreTables> tbs,
                                                                java.lang.String bigfieldFileDir)
                                                         throws java.lang.Exception

从接口复制的说明: CoreTablesService

根据指定的表id集合获取表模型，并将表模型中的大字段数据保存到bigfieldFileDir目录下

指定者:

getTableModelAndBigfieldFiles 在接口中 CoreTablesService

参数:

tbs - 需要导出的表模型集合

bigfieldFileDir - 保存大字段数据文件的路径 大字段数据文件的全路径：bigfieldFileDir + 表名_bigfield + 每行的rwid前两位 + rwid_列名.txt

返回:

表模型 list

抛出:

java.lang.Exception - 出错会抛出异常

getTableModelFromDbStructure

public java.util.List<CoreTables> getTableModelFromDbStructure()
                                                        throws java.lang.Exception

返回:

表模型List

抛出:

java.lang.Exception - 出错会抛出异常

importModelZip

public void importModelZip(java.lang.String zipFileName)
                    throws java.lang.Exception

从接口复制的说明: CoreTablesService

导入模型文件

指定者:

importModelZip 在接口中 CoreTablesService

参数:

zipFileName - 输入文件路径

抛出:

java.lang.Exception - 出错会抛出异常

fromFile

public CoreTables fromFile(java.lang.String filePath)
                    throws java.lang.Exception

从接口复制的说明: CoreTablesService

从文件反序列化成表模型对象

指定者:

fromFile 在接口中 CoreTablesService

参数:

filePath - 文件路径

返回:

表模型

抛出:

java.lang.Exception - 出错会抛出异常

exportModelZip

public java.io.File exportModelZip(java.lang.String outPutDir)
                            throws java.lang.Exception

从接口复制的说明: CoreTablesService

根据模型表导出模型zip压缩文件

指定者:

exportModelZip 在接口中 CoreTablesService

参数:

outPutDir - 输出目录

返回:

文件对象

抛出:

java.io.IOException - 出错抛出异常

java.lang.Exception - 出错会抛出异常

exportModelZip

public java.io.File exportModelZip(java.util.List<CoreTables> tbs,
                                   java.lang.String outPutDir)
                            throws java.lang.Exception

从接口复制的说明: CoreTablesService

导出模型文件

指定者:

exportModelZip 在接口中 CoreTablesService

参数:

tbs - 表模型list

outPutDir - 输出目录

返回:

文件对象

抛出:

java.lang.Exception - 出错会抛出异常

exportModelZip

public java.io.File exportModelZip(java.util.List<CoreTables> tbs,
                                   java.lang.String outPutDir,
                                   java.lang.String FileName)
                            throws java.lang.Exception

从接口复制的说明: CoreTablesService

导出模型文件

指定者:

exportModelZip 在接口中 CoreTablesService

参数:

tbs - 表模型list

outPutDir - 输出目录

FileName - 文件名称

返回:

文件对象

抛出:

java.lang.Exception - 出错会抛出异常

exportDb2ModelZip

public java.io.File exportDb2ModelZip(java.lang.String outPutDir,
                                      java.lang.String condition)
                               throws java.lang.Exception

从接口复制的说明: CoreTablesService

导出数据库的所有表成模型 zip文件 如果同时存在的物料表列与模型列会把模型的列信息带优先取出

指定者:

exportDb2ModelZip 在接口中 CoreTablesService

参数:

outPutDir - 输出目录

condition - 条件过滤 sql where 后面的条件

返回:

文件对象

抛出:

java.lang.Exception - 出错会抛出异常

java.io.IOException - 出错抛出异常

initSystem

public RetVo initSystem()
                 throws java.lang.Exception

从接口复制的说明: CoreTablesService

初始化系统

指定者:

initSystem 在接口中 CoreTablesService

返回:

RetVo

抛出:

java.lang.Exception - 出错会抛出异常

initSystem

public RetVo initSystem(java.util.List<java.lang.String> modelNames)
                 throws java.lang.Exception

从接口复制的说明: CoreTablesService

初始化系统

指定者:

initSystem 在接口中 CoreTablesService

参数:

modelNames - 指定的模型名列表 如果是null或者长度是零说明无过滤条件。全部模型都初始化

返回:

RetVo

抛出:

java.lang.Exception - 出错会抛出异常

importModelFile

public void importModelFile(java.net.URL fileUrl)
                     throws java.lang.Exception

导入模型文件

指定者:

importModelFile 在接口中 CoreTablesService

参数:

fileUrl - 文件路径

抛出:

java.lang.Exception - 出错会抛出异常

resetDataSource

@Transactional(propagation=REQUIRED)
public void resetDataSource()
                                                           throws java.sql.SQLException

从接口复制的说明: CoreTablesService

读取配置文件 重新启动数据库链接 TO DO 这个函数没作用暂时保留

指定者:

resetDataSource 在接口中 CoreTablesService

抛出:

java.sql.SQLException - 出错抛出数据库异常

saveJdbc

@Transactional(propagation=REQUIRED)
public void saveJdbc(CoreJdbcVo jdbc)
                                                    throws java.lang.Exception

从接口复制的说明: CoreTablesService

保存jdbc设置

指定者:

saveJdbc 在接口中 CoreTablesService

参数:

jdbc - CoreJdbcVo

抛出:

java.lang.Exception - 出错会抛出异常

scanModel

public void scanModel()
               throws java.lang.Exception

从接口复制的说明: CoreTablesService

* 扫描模型与数据结构的差异，并执行更新 1.数据库不存在表 创建 2.数据库存在表 1）检查字段差异 不存在字段 新增字段 存在字段 比较类型，长度 并尝试修改表结构 （各个数据库的修改限制规则不一，只要没报错误就说明修改成功） 2）记录差异 不存在记录 新增 存在记录 就更新记录

指定者:

scanModel 在接口中 CoreTablesService

抛出:

java.lang.Exception - 出错会抛出异常

isSyncTableModelToDB

public java.util.List<CoreTables> isSyncTableModelToDB(java.util.List<CoreTables> tables)
                                                throws java.lang.Exception

从接口复制的说明: CoreTablesService

判断是否表模型是否同步

指定者:

isSyncTableModelToDB 在接口中 CoreTablesService

参数:

tables - 表模型list

返回:

返回未同步的表模型

抛出:

java.lang.Exception - 出错会抛出异常

isSyncTableModelToDB

public java.lang.Boolean isSyncTableModelToDB(java.lang.String tbId)
                                       throws java.lang.Exception

从接口复制的说明: CoreTablesService

判断表是否创建且表结构中的列是否都创建

指定者:

isSyncTableModelToDB 在接口中 CoreTablesService

参数:

tbId - 表模型id

返回:

true 已经同步否则false

抛出:

java.lang.Exception - 出错会抛出异常

isExistsTableName

public java.lang.Boolean isExistsTableName(java.lang.String tbId,
                                           java.lang.String tableName)
                                    throws java.lang.Exception

从接口复制的说明: CoreTablesService

查询表名是否存在

指定者:

isExistsTableName 在接口中 CoreTablesService

参数:

tbId - 不为空时，过滤该表

tableName - 表模型表编号

返回:

存在返回true，否则返回false

抛出:

java.lang.Exception - 出错会抛出异常

modifySysSortValueNotNull

public int modifySysSortValueNotNull()
                              throws java.lang.Exception

从接口复制的说明: CoreTablesService

更新系统排序字段值不为空

指定者:

modifySysSortValueNotNull 在接口中 CoreTablesService

返回:

返回修改的记录数

抛出:

java.lang.Exception - 出错会抛出异常

findListExt

public java.util.List<CoreTables> findListExt(java.util.Map<java.lang.String,java.lang.Object> params)
                                       throws java.lang.Exception

从接口复制的说明: CoreTablesService

查询扩展，可以查询多个rwid

指定者:

findListExt 在接口中 CoreTablesService

参数:

params - 参数

返回:

同步的表模型List

抛出:

java.lang.Exception - 出错会抛出异常

checkTableDataFilterCnd

public boolean checkTableDataFilterCnd(java.lang.String rwid,
                                       java.lang.String condition)
                                throws java.lang.Exception

从接口复制的说明: CoreTablesService

校验数据过滤条件

指定者:

checkTableDataFilterCnd 在接口中 CoreTablesService

参数:

rwid - 表模型RWID

condition - where关键字之后的过滤条件

返回:

过滤条件校验成功返回true，如果为模型目录或者过滤条件为空也返回true，否则返回false

抛出:

java.lang.Exception - 出错会抛出异常 过滤条件不正确，则会抛出相应异常

setSysInitVersion

public void setSysInitVersion(java.lang.String version)
                       throws java.lang.Exception

指定者:

setSysInitVersion 在接口中 CoreTablesService

参数:

version - 版本号

抛出:

java.lang.Exception - 出错会抛出异常

getCreatedTablesByModelFile

public java.util.Map<java.lang.String,java.net.URL> getCreatedTablesByModelFile(java.util.List<java.net.URL> urls)
                                                                         throws java.lang.Exception

从接口复制的说明: CoreTablesService

根据模型文件获取已创建的表

指定者:

getCreatedTablesByModelFile 在接口中 CoreTablesService

参数:

urls - 路径

返回:

已创建的表

抛出:

java.lang.Exception - 出错会抛出异常

findListByTableNames

public java.util.List<CoreTables> findListByTableNames(java.util.List<java.lang.String> namesList)
                                                throws java.lang.Exception

从接口复制的说明: CoreTablesService

通过表名查询表模型

指定者:

findListByTableNames 在接口中 CoreTablesService

参数:

namesList - 表名list

返回:

表模型List

抛出:

java.lang.Exception - 出错会抛出异常

DragTable

public void DragTable(CoreTables coreTables)
               throws java.lang.Exception

从接口复制的说明: CoreTablesService

表拖拽

指定者:

DragTable 在接口中 CoreTablesService

参数:

coreTables - 表模型

抛出:

java.lang.Exception - 出错会抛出异常

getTableDataById

public java.util.List<java.util.LinkedHashMap<java.lang.String,java.lang.Object>> getTableDataById(java.lang.String tableName,
                                                                                                   java.lang.String rwid)

从接口复制的说明: CoreTablesService

根据主键rwid得到指定表的数据

指定者:

getTableDataById 在接口中 CoreTablesService

参数:

tableName - 表名

rwid - 主键值

返回:

表的数据list

getTableData

public java.util.List<java.util.LinkedHashMap<java.lang.String,java.lang.Object>> getTableData(java.lang.String tableName,
                                                                                               PageParams page)

从接口复制的说明: CoreTablesService

获取指定表的数据

指定者:

getTableData 在接口中 CoreTablesService

参数:

tableName - 表名

page - 分页的参数

返回:

表的数据list