cdatabase.java

jbuilder连接sql,很是用的！！学java一定是用的到的！

package first;

import java.sql.*;

public class CDatabase {
	boolean isconnected, eors, bors, isqueried;
	String url, user, pwd;
	Connection con;
	Statement st;
	ResultSet rs;
	ResultSetMetaData rsmd;
	DatabaseMetaData dbmt;
	
	protected void init(String DataSourceName, String Username, String Password){
		url = "jdbc:odbc:" + DataSourceName;
		user = Username;
		pwd = Password;
		eors = false;
		bors = false;
		isconnected = false;
		isqueried = false;
	}
	public CDatabase(String DataSourceName, String Username, String Password){
		init (DataSourceName, Username, Password);
	}
	public CDatabase(String DataSourceName){
		init (DataSourceName, "", "");
	}
	public String getInf(){
		String result = "";
		int i;
		try{
			if (rs.next()){
				for (i=1; i<=rsmd.getColumnCount(); i++){
					result += rs.getString(i) + ";";
				}
				eors = false;
				return (result);
			}else{
				eors = true;
				return ("EORS");
			}
		}catch (Exception ex){
			System.out.println(ex.getMessage());
			ex.printStackTrace ();
			return (ex.getMessage());
		}
	}	
	public String disconnect(){
		try{
			isconnected = false;
			con.close();
			return ("");
		}catch (Exception ex){
			System.out.println(ex.getMessage());
			ex.printStackTrace ();
			return (ex.getMessage());
		}
	}
	public String connect(){
		try{
			//加载驱动程序
			Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
			//建立连接
			con=DriverManager.getConnection(url, user, pwd);
			
			isconnected = true;
			//使用DatabaseMetaData 对象获取数据源相关信息
			dbmt=con.getMetaData();
			return ("");
/*			//获得数据源URL
			System.out.println("Data Source URL: "+dbmt.getURL());
			
			//获得驱动程序名称
			System.out.println("Driver Name: "+dbmt.getDriverName());
			//获得驱动程序版本号
			System.out.println("Driver Version: "+dbmt.getDriverVersion());
			//获得数据源连接的DBMS 名称
			System.out.println("Dtabase ProductName:"+dbmt.getDatabaseProductName());
			//获得数据源连接的DBMS 版本号
			System.out.println("Dtabase ProductVersion:"+dbmt.getDatabaseProductVersion());
*/
		}catch(Exception ex){
			System.out.println(ex.getMessage());
			ex.printStackTrace ();
			return (ex.getMessage());
		}
	}
	public String close(){
		try{
			rs.close();
			st.close();
			eors = false;
			bors = false;
			isqueried = false;
			return ("");
		}catch (Exception ex){
			System.out.println(ex.getMessage());
			ex.printStackTrace ();
			return (ex.getMessage());
		}
	}
	public String query(String SqlStr){
		try{
			//使用Statement、ResultSet、ResultSetMetaData查询数据库
			if (isqueried){
				this.close();
			}
			st = con.createStatement();
			rs = st.executeQuery(SqlStr);
			rsmd = rs.getMetaData();
			isqueried = true;
			return ("");
		}catch (Exception ex){
			System.out.println(ex.getMessage());
			ex.printStackTrace ();
			return (ex.getMessage());
		}
	}
	public String execute(String SqlStr){
		try{
			//使用Statement、ResultSet、ResultSetMetaData查询数据库
			if (isqueried){
				this.close();
			}
			st = con.createStatement();
			st.execute(SqlStr);
			return ("");
		}catch (Exception ex){
			System.out.println(ex.getMessage());
			ex.printStackTrace ();
			return (ex.getMessage());
		}
	}
}