?? parentbean.java
字號:
/**********************************************************
Copyright (C),2003-10-14, Beijing USTB.
All rights reserved.
Filename: ParentBean.java
Author: 劉中兵
Version 1.0
Date:2003-10-15
Description:封裝與數據庫類之上,Bean之下,用于選擇連接,釋放連接
Other:
Variable List:
1.DataBase db = new DataBase();
2.DealString ds = new DealString()//字符串處理時使用對象
Function List:
1.public ParentBean()//構造函數,初始化連接
2.public Connection getConn()//返回一個數據庫連接
3.public void createConn(int type,String url,String usr,String pwd)//取得不同數據庫的連接
4.public void closeConn()//釋放連接
5.public static void showConnNUM(boolean bool)//測試連接計數
//基本函數
6.protected ResultSet selectRecord(String sql)//查詢記錄
7.protected int insertRecord(Vector vect)//新增記錄
8.protected int updateRecord(Vector vect)//修改記錄
9.protected void deleteRecord(String sql)//刪除記錄
10.protected int executeUpdate(String sql)//執行語句
//輔助使用函數
11.public int makeID(String table,String field1,String field2,String value1,boolean type1)//產生唯一編號
public int makeID(String table,String field1,String field2,String field3,String value1,String value2,boolean type1,boolean type2)
public int makeID_Add1(String table,String field1,String field2,String value1,boolean type1)//產生唯一編號
public int makeID_Add1(String table,String field1,String field2,String field3,String value1,String value2,boolean type1,boolean type2)
12.public int toID(String table,String field1,String field2,String value1)//將名稱轉換為編號
13.public String toName(String table,String field1,String field2,String value1)//將編號轉換為名稱
14.protected Vector addVector(String field,String value,String type)//生成4、5的域值
15.public Vector getOnePage(String sql,int page,int records)//分頁時取得一頁的數據量
16.public int setSort(String table,String field1,String field2,String wherestr,String orderstr,boolean b)//為某一個字段進行重新排序
//查詢與更新LOB類型
17.public String QueryCLOB(String table,String wherestr,String clobfield)//查詢CLOB類型值
18.public int UpdateCLOB(String table,String wherestr,String blobfield,String blobvalue)//修改CLOB類型值
19.public String QueryBLOB(String table,String wherestr,String clobfield)//查詢BLOB類型值
20.public int UpdateBLOB(String table,String wherestr,String blobfield,String blobvalue)//修改BLOB類型值
21.public String QueryBLOB_JNDI(String table,String wherestr,String blobfield)//查詢BLOB類型值
22.public int UpdateBLOB_JNDI(String table,String wherestr,String blobfield,String blobvalue)//修改BLOB類型值
//數據庫結構信息
23.public Hashtable getDataBaseInfo()//數據庫信息
24.public Vector getTableList()//數據表列表
25.public Vector getTableStruct(String table)//數據表的結構
26.public Vector getResultSetData(ResultSet rs)//取得數據集內容
//對sql語句的分布處理
27.public void prepareStatement(String sql)//創建申明對象
28.public void executeQuery()//執行查詢
29.public boolean next()//轉向下一條
30.public String getObject(String field,String sqlType)//取得數據并根據數據類型轉化為字符串
31.public void setObject(int index,String value,String sqlType)//根據數據類型保存到數據庫
32.public void executeUpdate()//執行更新
33.public void closePstm()//關閉申明對象
34.public void closeRs()//關閉游標
History:
***********************************************************/
package com.ideas.bean;
import java.lang.*;
import java.util.*;
import java.sql.*;
import com.ideas.util.*;
public class ParentBean extends Object
{
//數據庫處理對象*/
protected DataBase db = new DataBase();
//字符串處理時使用對象*/
protected static DealString ds = new DealString();
//統計數據庫當前實際連接數*/
static int curnum = 0;
//統計數據庫接受請求連接數*/
static long sumnum= 0;
/**當前連接的數據庫類型*/
public static String DBType = "NULL";
public static String DBName = "";
public static String FilesPath = "";
//構造函數,初始化連接*/
public ParentBean()
{
//連接池取得連接
//db.getConnPool();
//System.out.println("從連接池創建連接成功!");
//從類里取得連接
//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("通過自身創建連接成功!");
DBType = "Oracle";
DBName = "jw";
//init();
// System.out.print("\r當前實際連接數:["+ds.toLengthStr(curnum+"",5)+"] 接受請求連接數:["+ds.toLengthStr(sumnum+"",10)+"]");
}
/**創建我的連接池*/
public boolean getMyConnPool()
{
return db.getMyConnPool();
}
/**釋放我的連接池*/
public boolean releaseMyConnPool()
{
return db.releaseMyConnPool();
}
public String getPara()
{
String tmp;
tmp = Configuration.ConfigFilePath;
tmp = tmp + Configuration.DB_URL + "|" + Configuration.DB_USERNAME + "|" + Configuration.DB_PASSWORD + "|";
return tmp;
}
public void init()
{
try
{
ResultSet rs = selectRecord("select XMMC from CODE_ZDB where ZDMC='上傳文件存放路徑'");
if(rs.next())
{
FilesPath = rs.getString(1);
}
Statement stm = rs.getStatement();
rs.close();
stm.close();
}
catch (SQLException e){}
{
}
}
public Vector getDataBySql(String sql) { return db.getData(sql); }
/**返回一個數據庫連接*/
public Connection getConn()
{
DBType = "Oracle";
DBName = "jw";
return db.conn;
}
/**取得不同數據庫的連接*/
public void createConn(int type,String ip,String port,String dbsrv,String dbname,String usr,String pwd)
{
/**
*type: 數據庫類型
* 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: 端口號
*dbsrv: 數據庫服務器(Informix專有)
*dbname: 數據庫名,或數據源名
*
*參數用法:
* 1.type不同數據庫使用不同序號；
* 2.Access只是用數據源dbname；
* 3.dbsrv只有使用Informix；
* 4.port對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+":"+port+"/"+dbname,usr,pwd);
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();
//System.out.println("釋放連接");
// System.out.print("\r當前實際連接數:["+ds.toLengthStr(curnum+"",5)+"] 接受請求連接數:["+ds.toLengthStr(sumnum+"",10)+"]");
}
public static void showConnNUM(boolean bool)
{
if(bool)//申請連接
{
curnum++;
sumnum++;
}
else//釋放連接
{
curnum--;
}
System.out.print("\r當前實際連接數:["+ds.toLengthStr(curnum+"",5)+"] 接受請求連接數:["+ds.toLengthStr(sumnum+"",10)+"]");
}
/**查詢記錄*/
protected ResultSet selectRecord(String sql)
{
return db.QuerySQL(sql);
}
/**新增記錄*/
protected int insertRecord(Vector vect)
{
/**Vector:第1項 表名(String)
// 第2項 列名(Vector[Field(String),Value(String,CLOB,BLOB),Type("CHAR","NUM","TIME","CLOB","BLOB")])*/
//臨時變量
String sqlField = "";//形如(F1,F2)
String sqlValue = "";//形如(V1,V2)
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -