sql.rar_java数据库连接_java连接_java连接数据库_sql数据库连接

package com.dyit.sql; import com.dyit.net.*; import java.util.*; import java.sql.*; import java.io.*; import oracle.jdbc.driver.*; import oracle.sql.*; /* * DyFileTable ver 0.91 beginner 0.9 * author :zhanghan * write-time :2002.5.10 * debug-time: 2002.5.28 * write for dyit-bsjs com * function : abstract blob table * * debug:0.91 change InputStream searchFile(DYDataSource ds) to InputStream searchFile(Connection con) * del InputStream searchFile(DYDataSource ds,String rowid) * for InputStream can't be holded when connection closed. * 0.92 debug SQLupdate() older sql lost the "column =" */ /**提供对单个带有大文件类型字段的数据库表的 插入，修改，删除，查询 *<p>所有列变量都以string类型传入， Date型变量 有两种写法 *<p>"YYYY-MM-DD" 或 "YYYY-MM-DD hh24:mi:ss" 注意空格 *<p>注意 ：实际数据库表中的日期 字段都要以"D_"开头，否则无法自动生成SQL语句 * */ public abstract class DyFileTable extends DYtable { /**表中的blob字段的列的列值 */ protected int blobset=-1; private InputStream fin; /**/ public void setFileValue(InputStream in)throws DyIOException,IOException{ if(in==null||in.available()<=0)throw new DyIOException(" file data stream is not available. "); fin = in; } /**设置全体列值 *@param String[] 列值 按构建顺序（如果库表中的列可以为空，该列可以缺项） *@return int 0 设置成功，1失败 */ public int setValues(java.lang.String[] Values){ hColumn.clear();//update 2001-9-10 v0.98 if(Values.length!=iTbColumn)return 1; for(int i=0;i<iTbColumn;i++)set(colName[i],Values[i]); return 0; } /**得到单条记录的插入语句 *<p>使用时可以将结果打印出来进行检查 *<p>但对于操作来说，该语句并不完整，因为大文件字段(blob)数据没有加入 *@return String 经过组合的SQL语句 */ public String SQLinsert(){ //String strsql = "insert into "+strTbName+" values("; if(blobset<0) return "blob column set error: have not set the blob column."; String strsql = " values(";//值 String strsql1 = "(";//列 Iterator iterCol = hColumn.keySet().iterator(); if(!iterCol.hasNext()) return " no value set, please set values first."; while(iterCol.hasNext()){ String stemp = (String)iterCol.next(); String stempValue = (String)hColumn.get(stemp); if((stempValue!=null&&!stempValue.equals(""))||stemp.equals(colName[blobset])){ strsql1 = strsql1+stemp+","; if(stemp.indexOf("D_")!=-1){ //表中日期数据以D_ 开头，对其格式化一下 if(stempValue.indexOf(":")>0) strsql = strsql+"to_date('"+stempValue+"','yyyy-mm-dd hh24:mi:ss'), "; else strsql = strsql+"to_date('"+stempValue+"','yyyy-mm-dd '), "; } else if(stemp.equals(colName[blobset])) strsql+=" empty_blob() , "; else strsql = strsql+"'"+stempValue+"' , "; } } strsql = "insert into "+strTbName+strsql1.substring(0,strsql1.lastIndexOf(","))+")"+strsql.substring(0,strsql.lastIndexOf(","))+")"; return strsql; } /**得到单条记录的修改语句 *使用时可以将结果打印出来进行检查 *@return String 经过组合的SQL语句 */ public String SQLupdate(){ return SQLupdate(null); } /**得到单条记录的修改语句 *使用时可以将结果打印出来进行检查 *@param String rowId oracle数据库中的伪列的值，可以唯一标示一条记录。注意：该值应从数据库中查询出来 *@return String 经过组合的SQL语句 *@update 2001-8-29 */ public String SQLupdate(String rowId){ String sPrimaryKey = null; if(blobset<0)return "blob column set error: have not set the blob column."; if(rowId==null||rowId.equals("")){ try{ sPrimaryKey = getPrmKeyCndtion();} catch(DySQLException e){ return "主键的值不全，不能进行相关操作"; } } else sPrimaryKey =" rowid ='"+rowId+"'"; String strsql = "Update "+strTbName+" set "; Iterator iterCol = hColumn.keySet().iterator(); if(!iterCol.hasNext()) return " no value set, please set values first."; while(iterCol.hasNext()){ String stemp = (String)iterCol.next(); String stempValue = (String)hColumn.get(stemp); if(stempValue!=null&&!stempValue.equals("")){ if(stemp.indexOf("D_")!=-1){ //表中日期数据以D_ 开头，对其格式化一下 if(stempValue.indexOf(":")>0) strsql = strsql+stemp+"=to_date('"+stempValue+"','yyyy-mm-dd hh24:mi:ss'), "; else strsql = strsql+stemp+"=to_date('"+stempValue+"','yyyy-mm-dd '), "; } else if(stemp.equals(colName[blobset])) strsql+=" empty_blob() , "; else strsql = strsql+stemp+"='"+stempValue+"' , "; } } strsql = strsql.substring(0,strsql.lastIndexOf(","))+" where "+sPrimaryKey; return strsql; } /**得到单条记录的删除语句 *使用时可以将结果打印出来进行检查 *@return String 经过组合的SQL语句 */ public String SQLdel(){ return SQLdel(null); } /**得到单条记录的删除语句 *使用时可以将结果打印出来进行检查 *@param String rowId oracle数据库中的伪列的值，可以唯一标示一条记录。注意：该值应从数据库中查询出来 *@return String 经过组合的SQL语句 *@update 2001-8-29 */ public String SQLdel(String rowId){ String sPrimaryKey = null; if(rowId==null||rowId.equals("")){ try{ sPrimaryKey = getPrmKeyCndtion();} catch(DySQLException e){ return "主键的值不全，不能进行相关操作"; } } else sPrimaryKey =" rowid ='"+rowId+"'"; String strsql = "delete from "+strTbName+" where "+sPrimaryKey; return strsql; } /**得到单条记录的查询语句 *使用时可以将结果打印出来进行检查 *@return String 经过组合的SQL语句 *@update 2001/8/7 */ public String SQLsearch(){ return SQLsearch(false); } /**得到单条记录的查询语句 *使用时可以将结果打印出来进行检查(建议一定要检查) *@param boolean bflag true 带有rowid 的查询语句 false 一般查询语句 *@return String 经过组合的SQL语句 *@update 2001/8/7 */ public String SQLsearch(boolean bflag){ String strsql = " , rowid "; String str = ""; try{str = getSearchCols();//如果返回“*” 就不能加" rowid, "了,已经不能返回"*"了 }catch(DySQLException e){ e.printStackTrace(); return " column values is not set "; } if(bflag)strsql = "select "+str+strsql+" from "+strTbName+" where "; else strsql = "select "+str+" from "+strTbName+" where "; int iflag =0; Iterator iterCol = hColumn.keySet().iterator(); while(iterCol.hasNext()){ String stemp = (String )iterCol.next(); String stempValue = (String)hColumn.get(stemp); if(stempValue!=null&&!stempValue.equals("")){ if(stemp.indexOf("D_")!=-1){ //表中日期数据以D_ 开头，对其格式化一下 if(stempValue.indexOf(":")>0) strsql = strsql+stemp+"=to_date('"+stempValue+"','yyyy-mm-dd hh24:mi:ss') and "; else strsql = strsql+stemp+"=to_date('"+stempValue+"','yyyy-mm-dd ') and "; } else strsql = strsql+stemp+"='"+stempValue+"' and "; iflag++; } } //hColumn有值 最后的strsql多余了 一个 "and" if(iflag>0)strsql = strsql.substring(0,strsql.lastIndexOf("and")); //hColumn空值 最后的strsql多余 "where" else strsql = strsql.substring(0,strsql.lastIndexOf("where")); return strsql; } /**得到单条记录的大文件字段的sql语句 *使用时可以将结果打印出来进行检查(建议一定要检查) *<p>用于插入和更新文件字段 *@param boolean bflag true 带有rowid 的查询语句 false 一般查询语句 *@return String 经过组合的SQL语句 *@update 2001/8/7 */ protected String SQLsearchBlob(String rowid)throws DySQLException{ if(blobset<0)throw new DySQLException("blob column set error: have not set the blob column."); String strsql = " select "+colName[blobset]+" from "+strTbName+" where "; int iflag =0; if(rowid!=null&& !rowid.equals(""))strsql+= " rowid ='"+rowid+"'"; else{ Iterator iterCol = hColumn.keySet().iterator(); while(iterCol.hasNext()){ String stemp = (String )iterCol.next(); String stempValue = (String)hColumn.get(stemp); if(stempValue!=null&&!stempValue.equals("")){ if(stemp.indexOf("D_")!=-1){ //表中日期数据以D_ 开头，对其格式化一下 if(stempValue.indexOf(":")>0) strsql = strsql+stemp+"=to_date('"+stempValue+"','yyyy-mm-dd hh24:mi:ss') and "; else strsql = strsql+stemp+"=to_date('"+stempValue+"','yyyy-mm-dd ') and "; } else strsql = strsql