?? parentbean.java
字號(hào):
package oa.main;
import java.lang.*;
import java.util.*;
import java.sql.*;
public class ParentBean extends Object
{
protected DataBase db = new DataBase();
protected static DealString ds = new DealString();
public static int count=0;
private static float memcount = 0.0f;
public static String DBType = "NULL";
public static String DBName = "";
public static String FilesPath = "";
public ParentBean()
{
// System.gc();
//連接池取得連接
//db.getConnPool();
//System.out.println("從連接池創(chuàng)建連接成功!");
//從類(lèi)里取得連接
//db.createConn("oracle.jdbc.driver.OracleDriver","jdbc:oracle:thin:@10.0.0.94:1521:hg","oaadminuser","lancom4454");
//db.createConn("oracle.jdbc.driver.OracleDriver","jdbc:oracle:thin:@192.168.0.53:1521:jw","jw","jw");
//db.createConn(oracle.jdbc.driver.OracleDriver","jdbc:oracle:thin:@10.2.4.253:1521:jw","jw","u2s0t0B3");
//db.createConn("oracle.jdbc.driver.OracleDriver","jdbc:oracle:thin:@192.168.0.63:1521:hg","oa","oa");
//從Access取得連接
//db.createConn("sun.jdbc.odbc.JdbcOdbcDriver","jdbc:odbc:HANFENG","admin","");
//System.out.println("通過(guò)自身創(chuàng)建連接成功!");
db.getMyConnPool();
DBType = "Oracle";
DBName = "jw";
init();
// System.out.print("\r當(dāng)前實(shí)際連接數(shù):["+ds.toLengthStr(curnum+"",5)+"] 接受請(qǐng)求連接數(shù):["+ds.toLengthStr(sumnum+"",10)+"]");
}
public void init()
{
ResultSet rs = selectRecord("select XMMC from CODE_ZDB where ZDMC='上傳文件存放路徑'");
Statement stmt = null;
try{
if(rs.next())
{
FilesPath = rs.getString(1);
}
}catch(Exception e){System.out.println("ParentBean::init(void)運(yùn)行時(shí)出錯(cuò)："+e);}
finally{
if(rs!=null)try{ stmt = rs.getStatement(); rs.close();}catch(Exception e){System.out.println("ParentBean::init(void)關(guān)閉記錄集rs時(shí)出錯(cuò)"+e);}
if(stmt!=null) try{stmt.close();}catch(Exception e){System.out.println("ParentBean::init(void)關(guān)閉聲明時(shí)statement出錯(cuò)"+e);}
}
}
/**返回一個(gè)數(shù)據(jù)庫(kù)連接*/
public Connection getConn()
{
DBType = "Oracle";
DBName = "jw";
return db.conn;
}
/**取得不同數(shù)據(jù)庫(kù)的連接*/
public void createConn(int type,String ip,String port,String dbsrv,String dbname,String usr,String pwd)
{
/**
*type: 數(shù)據(jù)庫(kù)類(lèi)型
* 1. Oracle url示例:"jdbc:oracle:thin:@localhost:1521:orcl"
* 2. Access url示例:"jdbc:odbc:HANFENG"
* 3. SQL Server url示例:"jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=pubs"
* 4. DB2 url示例:"jdbc:db2://localhost:5000/sample"
* 5. Informix url示例:"jdbc:informix-sqli://123.45.67.89:1533/testDB:INFORMIXSERVER=myserver"
* 6. Sybase url示例:"jdbc:sybase:Tds:localhost:5007/tsdata"
* 7. MySQL url示例:"jdbc:mysql://localhost/softforum?user=soft&password=soft1234&useUnicode=true&characterEncoding=8859_1"
* 8. PostgreSQL url示例:"jdbc:postgresql://localhost/soft"
* 9. Dbtools url示例:
* 10.Foxpro url示例:
* 11.Paradox url示例:
* 12.Excel url示例:
* 13.Text url示例:
* 14.XBase url示例:
* 15.dBase url示例:
* 16.FoxBase url示例:
* 17.SQLBase url示例:
* 18.Approach url示例:
*
*ip: 地址，如192.168.0.1,或localhost
*port: 端口號(hào)
*dbsrv: 數(shù)據(jù)庫(kù)服務(wù)器(Informix專(zhuān)有)
*dbname: 數(shù)據(jù)庫(kù)名,或數(shù)據(jù)源名
*
*參數(shù)用法:
* 1.type不同數(shù)據(jù)庫(kù)使用不同序號(hào)；
* 2.Access只是用數(shù)據(jù)源dbname；
* 3.dbsrv只有使用Informix；
* 4.port對(duì)MySQL,PostgreSQL不用；
* 5.ip,port,dbnme除了以上2和4之外都要使用；
*/
this.DBName = dbname;
if(type==1)//Oracle
{
db.createConn("oracle.jdbc.driver.OracleDriver","jdbc:oracle:thin:@"+ip+":"+port+":"+dbname,usr,pwd);
DBType = "Oralce";
}
else if(type==2)//Access
{
db.createConn("sun.jdbc.odbc.JdbcOdbcDriver","jdbc:odbc:"+dbname);
DBType = "Access";
}
else if(type==3)//SQL Server
{
db.createConn("com.microsoft.jdbc.sqlserver.SQLServerDriver","jdbc:microsoft:sqlserver://"+ip+":"+port+";DatabaseName="+dbname,usr,pwd);
DBType = "SQLServer";
}
else if(type==4)//DB2
{
db.createConn("com.ibm.db2.jdbc.app.DB2Driver","jdbc:db2://"+ip+":"+port+"/"+dbname,usr,pwd);
DBType = "DB2";
}
else if(type==5)//Informix
{
db.createConn("com.informix.jdbc.IfxDriver","jdbc:informix-sqli://"+ip+":"+port+"/"+dbname+":INFORMIXSERVER="+dbsrv,usr,pwd);
DBType = "Informix";
}
else if(type==6)//Sybase
{
db.createConn("com.sybase.jdbc.SybDriver","jdbc:sybase:Tds:"+ip+":"+port+"/"+dbname,usr,pwd);
DBType = "Sybase";
}
else if(type==7)//MySQL
{
db.createConn("org.gjt.mm.mysql.Driver","jdbc:mysql://"+ip+"/"+dbname+"user="+usr+"&password="+pwd+"&useUnicode=true&characterEncoding=8859_1");
DBType = "MySQL";
}
else if(type==8)//PostgreSQL
{
db.createConn("org.postgresql.Driver","jdbc:postgresql://"+ip+"/s"+dbname,usr,pwd);
DBType = "PostgreSQL";
}
else if(type==9)//Dbtools
{
DBType = "Dbtools";
}
else if(type==10)//Foxpro
{
DBType = "Foxpro";
}
else if(type==11)//Paradox
{
DBType = "Paradox";
}
else if(type==12)//Excel
{
DBType = "Excel";
}
else if(type==13)//Text
{
DBType = "Text";
}
else if(type==14)//XBase
{
DBType = "XBase";
}
else if(type==15)//dBase
{
DBType = "dBase";
}
else if(type==16)//FoxBas
{
DBType = "FoxBas";
}
else if(type==17)//SQLBase
{
DBType = "SQLBase";
}
else if(type==18)//Approach
{
DBType = "Approach";
}
else
{
DBType = "NULL";
}
}
/**釋放連接*/
public void closeConn()
{
DBType = "NULL";
//db.releaseConn();
db.releaseMyConnPool();
//System.out.println("釋放連接");
// System.out.print("\r當(dāng)前實(shí)際連接數(shù):["+ds.toLengthStr(curnum+"",5)+"] 接受請(qǐng)求連接數(shù):["+ds.toLengthStr(sumnum+"",10)+"]");
}
/**查詢(xún)記錄*/
public ResultSet selectRecord(String sql)
{
return db.QuerySQL(sql);
}
/**新增記錄*/
protected int insertRecord(Vector vect)
{
/**Vector:第1項(xiàng) 表名(String)
// 第2項(xiàng) 列名(Vector[Field(String),Value(String,CLOB,BLOB),Type("CHAR","NUM","TIME","CLOB","BLOB")])*/
//臨時(shí)變量
String sqlField = "";//形如(F1,F2)
String sqlValue = "";//形如(V1,V2)
String field = "";
String value = "";
String type = "";
for(int i=1;i<vect.size();i++)
{
//對(duì)某一個(gè)字段
Vector v_t = (Vector)vect.get(i);
field = (String)v_t.get(0);
value = (String)v_t.get(1);
if (value.indexOf("'")!=-1)
{
value = value.replaceAll("'","''");
}
type = (String)v_t.get(2);
//組合字段SQL
if(sqlField.equals(""))sqlField = "(";
else sqlField = sqlField + ",";
sqlField = sqlField + field;
//組合值SQL
if(sqlValue.equals(""))sqlValue = "(";
else sqlValue = sqlValue + ",";
if(value.equals(""))//為空時(shí)
{
sqlValue = sqlValue + "null";
}
else if(type.equals("CHAR"))//字符串
{
sqlValue = sqlValue + "'" + value + "'";
}
else if(type.equals("NUM"))//數(shù)值
{
sqlValue = sqlValue + value;
}
else if(type.equals("TIME"))//日期
{
sqlValue = sqlValue + "to_date('yyyy-MM-dd HH:mm:ss','" + value + "')";
}
else if(type.equals("CLOB"))//clob類(lèi)型
{
sqlValue = sqlValue + "empty_clob()";
}
else if(type.equals("BLOB"))//blob類(lèi)型
{
sqlValue = sqlValue + "empty_blob()";
}
}
sqlField = sqlField + ")";
sqlValue = sqlValue + ")";
String sql = "insert into " + (String)vect.get(0) + sqlField + " values" + sqlValue;
return db.ExecuteSQL(sql);
}
/**修改記錄*/
protected int updateRecord(Vector vect)
{
/**Vector:第1項(xiàng) 表名(String)
// 第2項(xiàng) 列名(Vector[Field(String),Value(String,CLOB,BLOB),Type("CHAR","NUM","TIME","CLOB","BLOB")])
// 第3項(xiàng) 條件(String sql)*/
//臨時(shí)變量
String sqlSet = "";//形如(Name='name',ID=9)
String field = "";
String value = "";
String type = "";
int i = 1;
int n = vect.size();
for(;i<(n-1);i++)
{
//對(duì)某一個(gè)字段
Vector v_t = (Vector)vect.get(i);
field = (String)v_t.get(0);
value = (String)v_t.get(1);
if (value.indexOf("'")!=-1)
{
value = value.replaceAll("'","''");
}
type = (String)v_t.get(2);
//組合字段SQL
if(sqlSet.equals(""))sqlSet = " ";
else sqlSet = sqlSet + ",";
sqlSet = sqlSet + field + "=";
if(value.equals("")&&type.equals("NUM"))//為空時(shí)
{
sqlSet = sqlSet + "null";
}
?? 快捷鍵說(shuō)明
復(fù)制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號(hào)
Ctrl + =
減小字號(hào)
Ctrl + -