package xz.xsr.pub.uip.util;
import java.sql.Blob;
import java.sql.CallableStatement;
import java.sql.Clob;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.Timestamp;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
import java.util.Vector;
import xz.xsr.pub.uip.modal.parser.Field;
import xz.xsr.pub.uip.modal.parser.UIConfiguration;
import xz.xsr.pub.util.Parameter;
public class DBUtil {
private static String DB_ADAPTEE_IMPL_CLASS = null;
public static synchronized Connection getConn(Parameter parameter)
throws Exception {
String debugMode = parameter.getSessionParam(UIConstant.UI_DEBUG_MODE);
if (DB_ADAPTEE_IMPL_CLASS == null||"1".equals(debugMode)) {
String uiConfPath = parameter
.getSessionParam(UIConstant.UI_CONF_PATH);
String xml = UIUtil.getFileContent(uiConfPath
+ "UIConfiguration.xml");
UIConfiguration obj = UIConfiguration.fromXml(xml);
DB_ADAPTEE_IMPL_CLASS = obj.getDbAdapter().getImplclass();
}
Class cl = Class.forName(DB_ADAPTEE_IMPL_CLASS);
DBAdaptee dbAdaptee = (DBAdaptee) cl.newInstance();
Connection conn = dbAdaptee.getDBConnection();
return conn;
}
public HashMap getPagingDataBySQL(ResultSet rs, Parameter parameter)
throws Exception {
int pageIndex = parameter.getRequestParam("pageIndex") != null ? Integer
.parseInt(parameter.getRequestParam("pageIndex"))
: 0;
int pageSize = parameter.getRequestParam("pageSize") != null ? Integer
.parseInt(parameter.getRequestParam("pageSize")) : 0;
rs.last();
int rowCount = rs.getRow();
rs.first();
rs.previous();
for (int i = 0; pageSize != -1 && i < pageIndex * pageSize; i++) {
rs.next();
}
ArrayList rList = resultSetToList(rs, pageSize);
HashMap result = new HashMap();
result.put("data", rList);
result.put("total", rowCount);
return result;
}
public ArrayList getDataListBySQL(ResultSet rs) throws Exception {
int pageSize = -1;//标识查所有数据
ArrayList rList = resultSetToList(rs, pageSize);
return rList;
}
public void executeSQL(Connection conn, String sql) throws Exception {
Statement stmt = conn.createStatement();
System.out.println("executeSQL sql="+sql);
try {
stmt.execute(sql);
} catch (SQLException e) {
throw new Exception("SQL无效："+e.getMessage()+"<br/>SQL："+sql);
}
stmt.close();
}
public ResultSet executeQuery(Connection conn, String sql) throws Exception
{
System.out.println("executeQuery sql="+sql);
ResultSet rs = null;
try {
rs = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,
ResultSet.CONCUR_UPDATABLE).executeQuery(sql);
} catch (SQLException e) {
throw new Exception("SQL无效："+e.getMessage()+"<br/>SQL："+sql);
}
return rs;
}
public FuncResult executeProcedure(Connection conn, String procName, ArrayList args) throws Exception {
FuncResult rs = new FuncResult();
String sql = "call " + procName + "(";
int argsLength = args.size();
for (int i = 0; i < argsLength; i++) {
sql += "?,";
}
sql += "?,?)";
System.out.println("executeProcedure sql="+sql);
CallableStatement cs = conn.prepareCall(sql);
String param = "";
for (int i = 0; i < argsLength; i++) {
cs.setString(i + 1, ((String[])args.get(i))[1]);
param += ","+ (((String[])args.get(i))[0]) + "="+ (((String[])args.get(i))[1]);
}
if(param.length()>0){
param = param.substring(1);
}
cs.registerOutParameter(argsLength + 1, oracle.jdbc.OracleTypes.INTEGER);
cs.registerOutParameter(argsLength + 2, oracle.jdbc.OracleTypes.VARCHAR);
System.out.println("参数："+JSONUtil.Encode(param));
try {
cs.execute();
} catch (SQLException e) {
throw new Exception("调用存储过程失败："+e.getMessage()+"<br/>存储过程："+ sql+",参数："+param);
}
rs.setFlag(cs.getInt(argsLength + 1)+"");
rs.setMsg(cs.getString(argsLength + 2) == null ? "" : cs.getString(argsLength + 2));
cs.close();
return rs;
}
public void insert(Connection conn, String tableName,HashMap valueMap2) throws SQLException{
StringBuffer sql1 = new StringBuffer("insert into "+tableName+"(");
StringBuffer sql2 = new StringBuffer(" values(");
Iterator it = valueMap2.keySet().iterator();
Vector vm = new Vector();
while(it.hasNext()){
String key = (String)it.next();
sql1.append(key).append(",");
sql2.append("?,");
vm.add(valueMap2.get(key));
}
String sql = sql1.substring(0,sql1.length()-1)+")"+sql2.subSequence(0, sql2.length()-1)+")";
System.out.println("insert sql="+sql);
System.out.println("参数："+JSONUtil.Encode(valueMap2));
PreparedStatement psd = conn.prepareStatement(sql);
fillStatement(psd, vm);
try{
psd.execute();
}catch(SQLException e){
throw new SQLException("数据插入失败："+e.getMessage()+"<br/>sql="+sql+",参数："+JSONUtil.Encode(valueMap2));
}
psd.close();
}
public void update(Connection conn, String tableName,HashMap valueMap,HashMap whereMap) throws SQLException{
StringBuffer sql1 = new StringBuffer("update "+tableName+" set ");
Iterator it = valueMap.keySet().iterator();
Vector v = new Vector();
while(it.hasNext()){
String key = (String)it.next();
sql1.append(key).append("=?,");
v.add(valueMap.get(key));
}
sql1 = new StringBuffer(sql1.substring(0, sql1.length()-1)).append(" where 1=1 ");
Iterator it2 = whereMap.keySet().iterator();
while(it2.hasNext()){
String key = (String)it2.next();
sql1.append(" and ").append(key).append("=?");
v.add(whereMap.get(key));
}
String sql = sql1.toString();
System.out.println("update sql="+sql);
System.out.println("参数："+JSONUtil.Encode(valueMap));
PreparedStatement psd = conn.prepareStatement(sql);
fillStatement(psd, v);
try{
psd.execute();
}catch(SQLException e){
throw new SQLException("数据更新失败："+e.getMessage()+"<br/>sql="+sql+",参数："+JSONUtil.Encode(valueMap));
}
psd.close();
}
public ArrayList<Field> getAllFieldByTabOrViewName(Connection conn, String objName) throws SQLException{
ResultSet rs = conn.createStatement().executeQuery( "SELECT COLUMN_NAME, DATA_TYPE\n" +
" FROM DBA_TAB_COLUMNS\n" +
" WHERE TABLE_NAME = '"+objName+"'");
ArrayList fields = new ArrayList();
while(rs.next()){
Field f = new Field();
f.setFieldName(rs.getString("COLUMN_NAME"));
f.setFieldType(rs.getString("DATA_TYPE"));
fields.add(f);
}
rs.close();
return fields;
}
public void delete(Connection conn,String tableName,HashMap whereMap) throws SQLException{
StringBuffer sql1 = new StringBuffer("delete from "+tableName+" where 1=1 ");
Vector v = new Vector();
Iterator it2 = whereMap.keySet().iterator();
while(it2.hasNext()){
String key = (String)it2.next();
sql1.append(" and ").append(key).append("=?");
v.add(whereMap.get(key));
}
String sql = sql1.toString();
System.out.println("delete sql="+sql);
System.out.println("参数："+JSONUtil.Encode(whereMap));
PreparedStatement psd = conn.prepareStatement(sql);
fillStatement(psd, v);
psd.execute();
psd.close();
}
public void fillStatement(PreparedStatement psd, Vector params) throws SQLException {
for(int index=0;index<params.size();index++){
Object objValue = params.get(index);
if (objValue instanceof String) {
String paraValue = (String) objValue;
psd.setString(index + 1, paraValue);
} else if (objVa
Java后端easyui框架sql查询 （207个子文件） 
DBUtil.class 13KB UIAction.class 8KB PersistenceCommandExec.class 7KB UIService.class 6KB XMLSQLMappingCfgLoader.class 4KB DyParameterParser.class 4KB XMLDataSourceCfgLoader.class 4KB JavaCommandExec.class 4KB CommandHelper.class 3KB SQLProcCommandExec.class 3KB UIParameterParser.class 3KB XMLUICfgLoader.class 3KB ExecCommandConverter.class 3KB JavaCommandCompiler.class 3KB ProcedureCommandCompiler.class 3KB QueryCommandExec.class 3KB CRUDCommandCompiler.class 3KB SQLMappingCfg.class 3KB UIConfiguration.class 3KB PersistenceCommandCompiler.class 3KB UIUtil.class 2KB SQLCrudCommandExec.class 2KB DataSource.class 2KB DataSourceCfg.class 2KB IncludeConverter.class 2KB QueryCommandConverter.class 2KB PersistenceCommand.class 2KB ExecCommand.class 2KB TableConverter.class 2KB FieldConverter.class 2KB PersistentCommandCompilerResult.class 2KB ComplilerResult.class 2KB JSONUtil.class 2KB ExeTimeEnum.class 2KB StringUtil.class 1KB JavaCommandCompilerResult.class 1KB FuncResult.class 1KB DateTransformer.class 1KB TestDbAdapter.class 1KB CommandExecFactory.class 1KB TestJavaFun.class 1KB Select.class 1KB ProcedureCommandCompilerResult.class 1KB CmdTypeEnum.class 1KB SQLBLock.class 1KB Persistence.class 947B Execute.class 935B DBConnThreadLocalFactory.class 912B CRUDCommandCompilerResult.class 894B QueryCommand.class 834B DyParameter.class 776B Field.class 758B Include.class 749B DBAdapter.class 573B Table.class 561B UIDBAdapter.class 516B UIConstant.class 514B SQLMappingCfgLoader.class 468B DataSourceCfgLoader.class 404B UICfgLoader.class 391B CommandCompiler.class 325B CommandExeHelper.class 313B Command.class 302B CommandExec.class 298B DBAdaptee.class 221B .classpath 1KB org.eclipse.wst.common.component 477B org.eclipse.wst.jsdt.ui.superType.container 49B
poi-ooxml-schemas-3.8.jar 4.49MB xmlbeans-2.3.0.jar 2.54MB itext-asian.jar 2.07MB ojdbc14.jar 1.84MB poi-3.8.jar 1.74MB itextpdf-5.2.1.jar 1.65MB poi-3.6-20091214.jar 1.47MB jackson-all-1.7.6.jar 932KB guava.jar 912KB poi-ooxml-3.8.jar 911KB javassist.jar 630KB xip.jar 621KB c3p0-0.9.1.2.jar 596KB commons-collections-3.2.1.jar 562KB struts.jar 537KB antlr-2.7.7.jar 435KB ldap.jar 426KB xstream-1.3.1.jar 421KB mysql-connector-java-3.1.10-bin.jar 409KB commons-configuration-1.10.jar 354KB log4j-1.2.11.jar 342KB proxool-cglib.jar 327KB dom4j-1.6.1.jar 307KB commons-httpclient-3.1.jar 298KB jsoup-1.8.1.jar 294KB jtds-1.2.2.jar 288KB commons-httpclient-3.0.1.jar 273KB commons-lang-2.3.jar 240KB jaxen-1.1-beta-6.jar 239KB commons-codec-1.6.jar 227KB jaxen-1.1.1.jar 222KB proxool-0.9.1.jar 196KB共 207 条
- 1
- 2
- 3
评论1
最新资源