?? database.java
字號:
String value = ds.toString(rs.getString(i));
hash.put(field,value);
}
vect.add(hash);
}
}catch(SQLException sqle){System.out.println("執行DataBase::getData(String)執行SQL語句 "+sql+" 時出錯;錯誤為:"+sqle);}
finally{
if(rs!=null){
try{
rs.close();
}catch(SQLException e){System.out.println("執行DataBase::getData(String)試圖釋放rs時出錯;\r\n錯誤為:"+e);}
}
if(pstm!=null){
try{
pstm.close();
}catch(SQLException e){System.out.println("執行DataBase::getData(String)試圖釋放pstm時出錯;\r\n錯誤為:"+e);}
}
}
return vect;
}
/**為某一個字段進行重新排序*/
public int setSort(String table,String field1,String field2,String wherestr,String orderstr,boolean b)
{
//寫入序列號,field2為唯一字段*/
try
{
String sql = "select "+field2+" from "+table;
if(!wherestr.equals(""))sql += " where "+wherestr;
sql += " "+orderstr;
pstm = conn.prepareStatement(sql);
rs = pstm.executeQuery();
PreparedStatement pstm_t = null;
int i = 1;
while(rs.next())
{
if(b)//為field2整型
{
sql = "update "+table+" set "+field1+"="+i+" where "+field2+"="+rs.getString(1);
}
else //為field2字符串
{
sql = "update "+table+" set "+field1+"="+i+" where "+field2+"='"+rs.getString(1)+"'";
}
pstm_t = conn.prepareStatement(sql);
pstm_t.executeUpdate();
i++;
}
pstm_t.close();
}catch(SQLException sqle){System.out.println("調用MyDataBase.setSort()函數錯誤:\r\n"+sqle);}
finally{
if(rs!=null){
try{
rs.close();
}catch(SQLException e){System.out.println("調用MyDataBase.setSort()試圖釋放rs時出錯;\r\n錯誤為:"+e);}
}
if(pstm!=null){
try{
pstm.close();
}catch(SQLException e){System.out.println("調用MyDataBase.setSort()試圖釋放pstm時出錯;\r\n錯誤為:"+e);}
}
}
return 0;
}
/**查詢CLOB類型值*/
public String QueryCLOB(String table,String wherestr,String clobfield)
{
String out = "";
try
{
String sqlCommand = "select "+clobfield+" from "+table;
if(!wherestr.equals(""))sqlCommand += " where "+wherestr;
pstm = conn.prepareStatement(sqlCommand);
rs = pstm.executeQuery();
if(rs.next())
{
oracle.sql.CLOB clob = (oracle.sql.CLOB)rs.getClob(clobfield);
if (clob != null)
{
Reader is = clob.getCharacterStream();
BufferedReader br = new BufferedReader(is);
String s = br.readLine();
while (s != null)
{
out += s;
s = br.readLine();
}
}
}
//out = (new DealString()).Replace(out,"\"","\"\"");
}
catch(SQLException sqle){System.out.println("調用MyDataBase.QueryCLOB()函數錯誤:\r\n"+sqle);}
catch(IOException iosql){System.out.println("調用MyDataBase.QueryCLOB()函數錯誤:\r\n"+iosql);}
finally{
if(rs!=null){
try{
rs.close();
}catch(SQLException e){System.out.println("試圖釋放rs時出錯;\r\n錯誤為:"+e);}
}
if(pstm!=null){
try{
pstm.close();
}catch(SQLException e){System.out.println("試圖釋放pstm時出錯;\r\n錯誤為:"+e);}
}
}
return out;
}
/**修改CLOB類型值*/
public int UpdateCLOB(String table,String wherestr,String clobfield,String clobvalue)
{
try
{
/* 設定不自動提交 */
boolean defaultCommit = conn.getAutoCommit();
conn.setAutoCommit(false);
/* 清空原CLOB對象 */
String sqlCommand = "UPDATE "+table+" set "+clobfield+"=EMPTY_CLOB()";
if(!wherestr.equals(""))sqlCommand += " where "+wherestr;
pstm = conn.prepareStatement(sqlCommand);
pstm.executeUpdate();
/* 查詢CLOB對象并鎖定 */
sqlCommand = "select "+clobfield+" from "+table;
if(!wherestr.equals(""))sqlCommand += " where "+wherestr;
sqlCommand += " for update";
pstm.clearBatch();
pstm.addBatch(sqlCommand);
rs = pstm.executeQuery();
while(rs.next())
{
/* 獲取此CLOB對象 */
oracle.sql.CLOB clob = (oracle.sql.CLOB)rs.getClob(clobfield);
clob.putString(1,clobvalue);
sqlCommand = "update "+table+" set "+clobfield+" = ? ";
if(!wherestr.equals(""))sqlCommand += " where "+wherestr;
PreparedStatement pstm_t = conn.prepareStatement(sqlCommand);
pstm_t.setClob(1,clob);
pstm_t.executeUpdate();
pstm_t.close();
}
/* 正式提交 */
conn.commit();
conn.setAutoCommit(defaultCommit);
}
catch(SQLException sqle)
{
System.out.println("調用MyDataBase.UpdateCLOB()函數錯誤:\r\n"+sqle);
return sqle.getErrorCode();
}
catch(Exception e){System.out.println("Exception:"+e);}
finally {
if(rs!=null){
try{
rs.close();
}catch(SQLException e){System.out.println("試圖釋放rs時出錯;\r\n錯誤為:"+e);}
}
if(pstm!=null){
try{
pstm.close();
}catch(SQLException e){System.out.println("試圖釋放pstm時出錯;\r\n錯誤為:"+e);}
}
}
return 0;
}
/**查詢BLOB類型值*/
public String QueryBLOB(String table,String wherestr,String blobfield)
{
String out = "";
try
{
String sqlCommand = "select "+blobfield+" from "+table;
if(!wherestr.equals(""))sqlCommand += " where "+wherestr;
pstm = conn.prepareStatement(sqlCommand);
rs = pstm.executeQuery();
if(rs.next())
{
oracle.sql.BLOB blob = (oracle.sql.BLOB)rs.getBlob(blobfield);
if (blob != null)
{
InputStream is = blob.getBinaryStream();
InputStreamReader isw = new InputStreamReader(is);
BufferedReader br = new BufferedReader(isw);
String s = br.readLine();
while (s != null)
{
out += s;
s = br.readLine();
}
}
}
out = (new DealString()).Replace(out,"\"","\"\"");
}
catch(SQLException sqle){System.out.println("調用MyDataBase.QueryBLOB()函數錯誤:\r\n"+sqle);}
catch(IOException iosql){System.out.println("調用MyDataBase.QueryBLOB()函數錯誤:\r\n"+iosql);}
finally{
if(rs!=null){
try{
rs.close();
}catch(SQLException e){System.out.println("試圖釋放rs時出錯;\r\n錯誤為:"+e);}
}
if(pstm!=null){
try{
pstm.close();
}catch(SQLException e){System.out.println("試圖釋放pstm時出錯;\r\n錯誤為:"+e);}
}
}
return out;
}
/**修改BLOB類型值*/
public int UpdateBLOB(String table,String wherestr,String blobfield,String blobvalue)
{
try
{
/* 設定不自動提交 */
boolean defaultCommit = conn.getAutoCommit();
conn.setAutoCommit(false);
/* 清空原CLOB對象 */
String sqlCommand = "UPDATE "+table+" set "+blobfield+"=EMPTY_BLOB()";
if(!wherestr.equals(""))sqlCommand += " where "+wherestr;
pstm = conn.prepareStatement(sqlCommand);
pstm.executeUpdate();
/* 查詢CLOB對象并鎖定 */
sqlCommand = "select "+blobfield+" from "+table;
if(!wherestr.equals(""))sqlCommand += " where "+wherestr;
sqlCommand += " for update";
pstm.clearBatch();
pstm.addBatch(sqlCommand);
rs = pstm.executeQuery();
while(rs.next())
{
/* 獲取此CLOB對象 */
oracle.sql.BLOB blob = (oracle.sql.BLOB)rs.getBlob(blobfield);
BufferedOutputStream out = new BufferedOutputStream(blob.getBinaryOutputStream());
byte b[] = blobvalue.getBytes();
out.write(b,0,b.length);
}
/* 正式提交 */
conn.commit();
conn.setAutoCommit(defaultCommit);
}
catch(SQLException sqle)
{
System.out.println("調用MyDataBase.UpdateBLOB()函數錯誤:\r\n"+sqle);
return sqle.getErrorCode();
}
catch(Exception e){System.out.println("調用MyDataBase.UpdateBLOB()出錯:"+e);}
finally{
if(rs!=null){
try{
rs.close();
}catch(SQLException e){System.out.println("調用MyDataBase.UpdateBLOB()試圖釋放rs時出錯;\r\n錯誤為:"+e);}
}
if(pstm!=null){
try{
pstm.close();
}catch(SQLException e){System.out.println("調用MyDataBase.UpdateBLOB()試圖釋放pstm時出錯;\r\n錯誤為:"+e);}
}
}
return 0;
}
/**查詢BLOB類型值*/
public String QueryBLOB_JNDI(String table,String wherestr,String blobfield)
{
String sql = "select "+blobfield+" from "+table;
if(!wherestr.equals(""))sql += " where "+wherestr;
prepareStatement(sql);
executeQuery();
next();
//InputStream is = rs.getBinaryStream("ziduan");
//return (new DealFile()).readCHStr(is);
String out = getObject(blobfield,"BLOB");
closeRs();
closePstm();
return out;
}
/**修改BLOB類型值*/
public int UpdateBLOB_JNDI(String table,String wherestr,String blobfield,String blobvalue)
{
String sql = "UPDATE "+table+" set "+blobfield+"=?";
if(!wherestr.equals(""))sql += " where "+wherestr;
prepareStatement(sql);
setObject(1,blobvalue,"BLOB");
executeUpdate();
closePstm();
return 0;
}
/**往數據庫中插入一個新的CLOB對象*/
public int clobInsert(String sql,String table,String wherestr,String clobfield,String infile)
{
int out = ExecuteSQL(sql);//Insert語句
out = clobModify(table,wherestr,clobfield,infile);
return out;
}
/**修改CLOB對象（是在原CLOB對象基礎上進行覆蓋式的修改）*/
public int clobModify(String table,String wherestr,String clobfield,String infile)
{
try
{
/* 設定不自動提交 */
boolean defaultCommit = conn.getAutoCommit();
conn.setAutoCommit(false);
/* 查詢此CLOB對象并鎖定 */
String sqlCommand = "select "+clobfield+" from "+table;
if(!wherestr.equals(""))sqlCommand += " where "+wherestr;
sqlCommand += " for update ";
pstm = conn.prepareStatement(sqlCommand);
rs = pstm.executeQuery();
while (rs.next())
{
/* 取出此CLOB對象 */
oracle.sql.CLOB clob = (oracle.sql.CLOB)rs.getClob(clobfield);
/* 進行覆蓋式修改 */
BufferedReader in = new BufferedReader(new FileReader(infile));
BufferedWriter out = new BufferedWriter(clob.getCharacterOutputStream());
int c;
while ((c=in.read())!=-1)
{
out.write(c);
}
in.close();
out.close();
}
rs.close();
pstm.close();
/* 正式提交 */
conn.commit();
/* 恢復原提交狀態 */
conn.setAutoCommit(defaultCommit);
}
catch(SQLException sqle)
{
System.out.println("調用DataBase.clobModify()函數錯誤:\r\n"+sqle);
return sqle.getErrorCode();
}
catch(IOException iosql){System.out.println("調用DataBase.clobModify()函數錯誤:\r\n"+iosql);}
return 0;
}
/**替換CLOB對象（將原CLOB對象清除，換成一個全新的CLOB對象）*/
public int clobReplace(String table,String wherestr,String clobfield,String infile)
{
int out = 0;
try
{
/* 設定不自動提交 */
boolean defaultCommit = conn.getAutoCommit();
conn.setAutoCommit(false);
/* 清空原CLOB對象 */
String sqlCommand = "update "+table+" set "+clobfield+"=EMPTY_CLOB()";
if(!sqlCommand.equals(""))sqlCommand += " where "+wherestr;
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -