一个用配制文件衔接数据库的Java工具类[Java编程]

大家用的时刻只需求把配置文件里的内容改掉便可以啦!

配置文件Database.Property内容

jdbc.drivers=sun.jdbc.odbc.JdbcOdbcDriver
jdbc.url=jdbc:odbc:mydata
jdbc.username=system
jdbc.password=manager

JAVABEAN文件内容

package community.database;
import java.io.*;
import java.util.*;
import java.sql.*;
/** *//**
*
Title: Database Manager
*
Description: Connect Database
*
Copyright: Copyright　2002 YaoGuodong
*
Company:
* @author unascribed YaoGuodong 姚国栋
* @version 1.0
* @email net_spirit@163.com
* @QQ 16898283
* @转载的时刻请保存版权信息
*/
public class DBManager ...{
/** *//**getConnection() 得到衔接数据库的属性文件内容,并返回衔接后果集
　@throws SQLException
　@throws IOException
　@throws Exception
　声明drivers,得到数据库的驱动程序
　声明url,得到衔接远程数据库的URL
　声明username,得到衔接远程数据库的用户名
　声明password,得到衔接远程数据库的密码
　@return DriverManger.getConnection(url,username,passowrd);
　*/
public Connection getConnection() throws SQLException,IOException,Exception ...{
　 Properties props = new Properties();
　 //String fileName = "e:Database.Property";
　 //FileInputStream in = new FileInputStream(fileName);
　 InputStream in = getClass().getResourceAsStream("/Database.Property") ;
　 props.load(in);
　 String drivers = props.getProperty("jdbc.drivers");
　 if (drivers!=null)
　　　 ...{ System.setProperty("jdbc.drives",drivers); }
　 String url = props.getProperty("jdbc.url");
　 String username = props.getProperty("jdbc.username");
　 String password = props.getProperty("jdbc.password");
　 Class.forName(drivers);
　 return DriverManager.getConnection(url,username,password);
}
/** *//**DBManager()
　* 衔接数据库
　*/
public DBManager() ...{
　 try...{
　　 conn = getConnection();
　　 stmt=conn.createStatement();
　　 System.out.println("Connect Database is Ok!");
　 }
　 catch(Exception e)...{
　　 System.out.println("Connect Database Failed!:"+e);
　　 }
}
/** *//** executeQuery()办法,查询SQL后果
　@param sqlwords 为传入的查询的sql语句
　@return rs　为返回的查询后果集
　*/
public ResultSet executeQuery(String sqlwords) ...{
　 this.sqlwords=sqlwords;
　 try...{
　　 rs=stmt.executeQuery(sqlwords);
　 }
　 catch(SQLException ex)...{
　　 System.out.println("Execute Query Sql Failed!:" + ex.getMessage());
　 }
　 return rs;
}
/** *//** executeUpdate()办法,改正数据库记录
　@param sqlwords 为传入的查询的sql语
　@return true|false
　*/
public boolean executeUpdate(String sqlwords) ...{
　 this.sqlwords=sqlwords;
　 try ...{
　　 stmt.executeUpdate(sqlwords);
　　 return true;
　 }
　 catch(SQLException ex) ...{
　　 System.err.println("Execute Update Sql Failed!: " + ex.getMessage());
　　 return false;
　 }
}
/** *//** executeInsert()办法,插入新的数据库记录
　@param sqlwords 为传入的插入的sql语
　@return true|false
　*/
　public boolean executeInsert(String sqlwords) ...{
　 this.sqlwords=sqlwords;
　 try ...{
　　 stmt.executeUpdate(sqlwords);
　　 return true;
　 }
　 catch(SQLException ex) ...{
　　 System.err.println("Execute Insert Sql Failed!: " + ex.getMessage());
　　 return false;
　 }
}
/** *//** executeDelete()办法,删除数据库记录
　@param sqlwords 为传入的删除的sql语
　@return true|false
　*/
　public boolean executeDelete(String sqlwords) ...{
　 this.sqlwords=sqlwords;
　 try ...{
　　 stmt.executeUpdate(sqlwords);
　　 return true;
　 }
　 catch(SQLException ex) ...{
　　 System.err.println("Execute Delete Sql Failed!: " + ex.getMessage());
　　 return false;
　 }
}
/** *//** close()办法,断开数据库的衔接
　@return true|false
　*/
public boolean close()
...{
　 try ...{
　　 if(rs != null)...{ rs.close(); }
　　 if(stmt != null)...{ stmt.close(); }
　　 if(conn != null)...{ conn.close(); }
　　 return true;
　 }
　 catch(Exception e) ...{
　　 System.out.print("Clost Database Connect Failed!:"+e);
　　 return false;
　 }
}
/** *//**
　* 声明conn
　* 声明rs后果集
　* 声明stmt语气
　* 声明sqlwords关键字
　*/
Connection conn = null;
ResultSet rs = null;
Statement stmt = null;
private String sqlwords = null;