一个用配制文件连接数据库的Java工具类
来源:岁月联盟
时间:2007-08-03
大家用的时候只需要把配置文件里的内容改掉就可以啦!
配置文件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;