hibernate动态数据库进化版 - JAVA

String port, String dataBaseName, String username, String password,
String schema, String catalog, String tableName, String idColumn,
Long id) {
dynamicSqlOperateBefore(dialect, driverClass, ipAddress, port,
dataBaseName, username, password, schema, catalog, tableName);
StringBuilder sql = new StringBuilder();
sql.append("select * from " + tableName + " where " + idColumn + "="
+ id);
query = session.createSQLQuery(sql.toString()).setResultTransformer(
Transformers.ALIAS_TO_ENTITY_MAP);
Object object = query.uniqueResult();

// session.close();
return object;
}

/**
* 获取对象列表
* @param dialect
* @param driverClass
* @param ipAddress
* @param port
* @param dataBaseName
* @param username
* @param password
* @param schema
* @param catalog
* @param tableName
* @param sortColumn
* @param params
* @param iDisplayStart
* @param iDisplayLength
* @return
*/
public List> getObjectList(String dialect, String driverClass,
String ipAddress, String port, String dataBaseName,
String username, String password, String schema, String catalog,
String tableName, String sortColumn, Map params,
Integer iDisplayStart, Integer iDisplayLength) {
dynamicSqlOperateBefore(dialect, driverClass, ipAddress, port,
dataBaseName, username, password, schema, catalog, tableName);

if (iDisplayStart == null) {
iDisplayStart = 1;
if (iDisplayLength == null) {
iDisplayLength = 10;
}
}
StringBuilder sql = new StringBuilder();
String dbType = DynamicSessionFactory.getConfiguration().getProperty("hibernate.connection.driver_class");
if (dbType.contains("oracle")) {
// oracle分页
sql.append("select * from(select A.*, rownum rn from (");
} else if(dbType.contains("mysql")) {
}
sql.append("select * from " + tableName + " where 1=1");
if (params != null) {
if (!params.isEmpty()) {
Set keys = params.keySet();
for (String paramKey : keys) {
String paramVal = params.get(paramKey);
sql.append(" and " + paramKey + "='" + paramVal + "'");
}
}
}

if (sortColumn != null && sortColumn != "") {
sql.append(" order by "+sortColumn+" desc");
}

if (dbType.contains("oracle")) {
sql.append(") A where rownum <= " + iDisplayLength + ") where rn >= "
+ iDisplayStart);
} else if(dbType.contains("mysql")) {
// mysql分页
sql.append(" limit "+iDisplayStart+" ,"+iDisplayLength);
}

query = session.createSQLQuery(sql.toString()).setResultTransformer(
Transformers.ALIAS_TO_ENTITY_MAP);
List> list = query.list();

return list;
}

/**
* 记录总数查询
* @param dialect
* @param driverClass
* @param ipAddress
* @param port
* @param dataBaseName
* @param username
* @param password
* @param schema
* @param catalog
* @param tableName
* @param params
* @param iDisplayStart
* @param iDisplayLength
* @return
*/
public int getTotalCount(String dialect, String driverClass,
String ipAddress, String port, String dataBaseName,
String username, String password, String schema, String catalog,
String tableName, Map params,
Integer iDisplayStart, Integer iDisplayLength) {
dynamicSqlOperateBefore(dialect, driverClass, ipAddress, port,
dataBaseName, username, password, schema, catalog, tableName);

StringBuilder sql = new StringBuilder();
sql.append("select count(*) from " + tableName);
query = session.createSQLQuery(sql.toString());
int totalCount = ((Nu

hibernate动态数据库进化版 (十一)