com.fr.data.core

类 DataCoreUtils

java.lang.Object

com.fr.data.core.DataCoreUtils

public class DataCoreUtils
extends java.lang.Object

数据集相关的工具类

方法概要

方法

限定符和类型	方法和说明
static int	calculateOracleType(java.lang.String type) 计算oracle数据库中的字段类型
static java.lang.String	createColumnSelectSQL(java.lang.String schema, java.lang.String tableName, Dialect dialect) 获取查询列名的SQL
static java.lang.String	createColumnSelectSQL(Table table, Dialect dialect) 获取查询列名的SQL
static java.lang.String	createSelectSQL(java.lang.String schema, java.lang.String tableName) 新建立SQL.
static java.lang.String	createSelectSQL(java.lang.String schema, java.lang.String tableName, Dialect dialect) 新建立SQL.
static java.lang.String	createSelectSQL(Table table, Dialect dialect) 根据表名，新建立SQL.
static java.lang.String	createSelectSQL(Table table, java.lang.String[] columnNames, Dialect dialect) 根据表名和列名[],新建立SQL.
static TableData	getClonedTableData(DatasourceManagerProvider datasourceManager, java.lang.String dsName) Gets the cloned TableData of the specified name.
static int	getColumnIndexByName(DataModel model, java.lang.String name) 返回列名所在的列序号
static int[]	getColumnIndics(DataModel resultSet, java.lang.String[] fieldNames)
static java.lang.String[]	getDatabaseSchema(Connection database) 返回数据连接的所有schemas
static java.lang.String	getFunctionBriefName(DataFunction function)
static java.lang.String	getFunctionDisplayName(DataFunction function) 计算Function的显示名字,将他们后面的"Function"字符串去掉.
static java.lang.String	getOnlyColumnName(java.util.List columnNameList, java.lang.String currentColumnName) Return the only column name.
static java.util.List	getProcedures(Connection datasource, java.lang.String[] schemas, boolean isOracle, boolean isOracleSysSpace) 返回存储过程列表集合
static java.lang.Object	getResultSetObject(java.sql.ResultSet resultSet, int columnType, int index, Dialect dialect, SQLTypeHandler handler) 返回Resultset的类
static java.lang.Object	getResultSetObject(java.sql.ResultSet resultSet, int columnType, int index, java.lang.String originalCharsetName, java.lang.String newCharsetName, Dialect dialect, SQLTypeHandler handler, boolean needCharsetChange) 返回Resultset的类
static java.lang.Object	getTableDataValue(DataModel rs, int rowIndex, int columnIndex) columnIndex >= 0 表示取从TableData中取实际的列号的值, columnIndex == -1 表示取行序号, 在这里不对columnIndex的范围作判断,因为在TableData里面自有判断.
static TableProcedure[]	getTables(Connection database, java.lang.String type, java.lang.String schema, boolean isOracleSystemSpace) ben:有必要分开取table,view,procedure，全部都取意义不大，而且耗时很长 august：这个方法相当搓啊，性能很差。
static void	putProcedureMap(Connection datasource, java.util.Map schemaTableMap) 过程集合
static java.lang.Object	readDictObject(java.lang.String str) 读取字库
static void	refreshSchema(Connection database) 刷新模式
static void	refreshTables(Connection database, java.lang.String type, java.lang.String schema) 刷新数据集
static java.lang.String	writeDictObject(java.lang.Object obj) 写字库

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

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

方法详细资料

getColumnIndexByName

public static int getColumnIndexByName(DataModel model,
                       java.lang.String name)
                                throws TableDataException

返回列名所在的列序号

参数:

model - 数据集

name - 列名

返回:

列序号

抛出:

TableDataException - 数据集异常

calculateOracleType

public static int calculateOracleType(java.lang.String type)

计算oracle数据库中的字段类型

参数:

type - 类型

返回:

对应的type

getFunctionBriefName

public static java.lang.String getFunctionBriefName(DataFunction function)

getFunctionDisplayName

public static java.lang.String getFunctionDisplayName(DataFunction function)

计算Function的显示名字,将他们后面的"Function"字符串去掉.

参数:

function - 数据函数

返回:

Function的显示名字

createSelectSQL

public static java.lang.String createSelectSQL(java.lang.String schema,
                               java.lang.String tableName,
                               Dialect dialect)

新建立SQL.

参数:

schema - 表

tableName - 表名

dialect - 用于处理数据库之间差异的方言

返回:

sql字符串

createSelectSQL

public static java.lang.String createSelectSQL(java.lang.String schema,
                               java.lang.String tableName)

新建立SQL.

参数:

schema - 模式

tableName - 表名

返回:

sql字符串

createSelectSQL

public static java.lang.String createSelectSQL(Table table,
                               Dialect dialect)

根据表名，新建立SQL.

参数:

table - 表

dialect - 用于处理数据库之间差异的方言

返回:

结果字符串

createSelectSQL

public static java.lang.String createSelectSQL(Table table,
                               java.lang.String[] columnNames,
                               Dialect dialect)

根据表名和列名[],新建立SQL.

参数:

table - 表

columnNames - 列名

dialect - 用于处理数据库之间差异的方言

返回:

结果字符串

createColumnSelectSQL

public static java.lang.String createColumnSelectSQL(java.lang.String schema,
                                     java.lang.String tableName,
                                     Dialect dialect)

获取查询列名的SQL

参数:

schema -

tableName -

dialect -

返回:

createColumnSelectSQL

public static java.lang.String createColumnSelectSQL(Table table,
                                     Dialect dialect)

获取查询列名的SQL

参数:

table -

dialect -

返回:

getResultSetObject

public static java.lang.Object getResultSetObject(java.sql.ResultSet resultSet,
                                  int columnType,
                                  int index,
                                  java.lang.String originalCharsetName,
                                  java.lang.String newCharsetName,
                                  Dialect dialect,
                                  SQLTypeHandler handler,
                                  boolean needCharsetChange)
                                           throws java.sql.SQLException

返回Resultset的类

参数:

resultSet - 结果集

columnType - 列类型

index - 序号

originalCharsetName - 默认字符集

newCharsetName - 新的字符集

dialect - 数据库方言

handler - 数据库语言中字段类型差异类

needCharsetChange - 是否需要改变字符集

返回:

结果集对象

抛出:

java.sql.SQLException - sql异常

getClonedTableData

public static TableData getClonedTableData(DatasourceManagerProvider datasourceManager,
                           java.lang.String dsName)
                                    throws java.lang.Exception

Gets the cloned TableData of the specified name. 克隆数据集

参数:

datasourceManager - 数据集管理类

dsName - 数据连接名

返回:

数据集

抛出:

java.lang.Exception

getResultSetObject

public static java.lang.Object getResultSetObject(java.sql.ResultSet resultSet,
                                  int columnType,
                                  int index,
                                  Dialect dialect,
                                  SQLTypeHandler handler)
                                           throws java.sql.SQLException

返回Resultset的类

参数:

resultSet - 结果集

columnType - 列类型

index - 序号

dialect - 数据库方言

handler - 数据库语言中字段类型差异类

返回:

结果集对象

抛出:

java.sql.SQLException - sql异常

writeDictObject

public static java.lang.String writeDictObject(java.lang.Object obj)

写字库

参数:

obj - 字段

返回:

处理后的结果值

readDictObject

public static java.lang.Object readDictObject(java.lang.String str)

读取字库

参数:

str - 字段

返回:

符合的结果值

getTableDataValue

public static java.lang.Object getTableDataValue(DataModel rs,
                                 int rowIndex,
                                 int columnIndex)

columnIndex >= 0 表示取从TableData中取实际的列号的值, columnIndex == -1 表示取行序号, 在这里不对columnIndex的范围作判断,因为在TableData里面自有判断.

参数:

rs - 数据集

rowIndex - 行序号

columnIndex - 列序号

返回:

实际的列号的值

getOnlyColumnName

public static java.lang.String getOnlyColumnName(java.util.List columnNameList,
                                 java.lang.String currentColumnName)

Return the only column name.
The method will check column name. Make it only in the list.

参数:

columnNameList - 列集合

currentColumnName - 当前列名

返回:

返回处理后的列名

getDatabaseSchema

public static java.lang.String[] getDatabaseSchema(Connection database)

返回数据连接的所有schemas

参数:

database - 数据连接

返回:

所有schema

refreshSchema

public static void refreshSchema(Connection database)

刷新模式

参数:

database - 数据连接

getTables

public static TableProcedure[] getTables(Connection database,
                         java.lang.String type,
                         java.lang.String schema,
                         boolean isOracleSystemSpace)
                                  throws java.lang.Exception

ben:有必要分开取table,view,procedure，全部都取意义不大，而且耗时很长 august：这个方法相当搓啊，性能很差。尤其是对oracle来说：一般schema有很多吧，那么下面这个方法就要执行许多遍，那么每次都要做重复的if——else判断了。 而且，原先FRContext.getCommonOperator().getTableProcedure这个方法的localenv实现里，每次都是建立连接释放连接，所以更挫了 原来的设计器到时无所谓，可是现在的需求是一次性全部加载所有的存储过程或者表，这个方法就不行了 实际上if——else只要第一次就行了,它应该放在方法体外面,同时拆分方法

参数:

database - 数据连接

type - 类型

schema - 模式

isOracleSystemSpace - 是否展示系统表空间的

抛出:

java.lang.Exception

getProcedures

public static java.util.List getProcedures(Connection datasource,
                           java.lang.String[] schemas,
                           boolean isOracle,
                           boolean isOracleSysSpace)
                                    throws java.lang.Exception

返回存储过程列表集合

参数:

datasource - 数据连接

schemas - 模式s

isOracle - 是否为oracle

isOracleSysSpace - 是否展示oracle系统空间表

返回:

storeproduce列表集合

抛出:

java.lang.Exception - 异常

putProcedureMap

public static void putProcedureMap(Connection datasource,
                   java.util.Map schemaTableMap)

过程集合

参数:

datasource - 数据连接

schemaTableMap - 模式表集合

refreshTables

public static void refreshTables(Connection database,
                 java.lang.String type,
                 java.lang.String schema)

刷新数据集

参数:

database - 数据连接

type - 类型

schema - 模式

getColumnIndics

public static int[] getColumnIndics(DataModel resultSet,
                    java.lang.String[] fieldNames)