利用属性文件连接oracle数据库

终6871

　　本文将介绍如何利用属性文件来获取数据库的相应信息，从而达到查询数据库的目的，本题目以oracle为例。
　　1、首先创建一个属性文件如下（此属性文件创建在项目中的src下的com.properties包下,名为OracleDriver.properties）：

dbdriver=oracle.jdbc.driver.OracleDriver
dburl=jdbc:oracle:thin:@192.168.1.30:1521:orcl
dbuser=scott
dbpasswd=tiger
　　2、创建读取属性文件的类如下：

package com.test;
import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;
public class Env extends Properties {
private static Env instance ;
//获得属性文件实例
public static Env getInstance(){
if(instance!=null){
return instance ;
}else{
makeInstance() ;
return instance ;
}
}
//此处添加synchronized关键的目的地是为了实现线程同步问题
public static synchronized void makeInstance(){
instance = new Env() ;
}
//因为用到单例模式，所以此构造方法为私有的
private Env(){
InputStream is = this.getClass().getResourceAsStream("/com/properties/OracleDriver.properties") ;
try {
this.load(is) ;
} catch (IOException e) {
// TODO Auto-generated catch block
System.out.println("没有找到配置文件") ;
e.printStackTrace();
}
}
}

　　3、创建连接数据库类如下：

package com.test;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class ConnectPropertiesManager {
//获得数据库连接
public static synchronized Connection getConn(){
Connection conn = null ;
//依次从属性文件中获得数据库的相关信息
String dbdriver = Env.getInstance().getProperty("dbdriver") ;
String dburl = Env.getInstance().getProperty("dburl") ;
String dbuser = Env.getInstance().getProperty("dbuser") ;
String dbpasswd = Env.getInstance().getProperty("dbpasswd") ;
try {
//注册数据库驱动并连接数据库
Class.forName(dbdriver) ;
conn = DriverManager.getConnection(dburl,dbuser,dbpasswd) ;
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e){
e.printStackTrace() ;
}
return conn ;
}
//获得要执行的SQL语句
public static synchronized PreparedStatement getPrep(Connection conn,String sql){
PreparedStatement pstmt = null ;
try {
pstmt = conn.prepareStatement(sql) ;
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return pstmt ;
}
//关闭所有用到的数据库资源
public static void closeAll(Connection conn,Statement stmt,ResultSet rs){
if(conn!=null){
try {
conn.close() ;
conn = null ;
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
if(stmt!=null){
try {
stmt.close() ;
stmt = null ;
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
if(rs!=null){
try {
rs.close() ;
rs = null ;
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}

　　5、创建测试类如下：

package com.test;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

public class Test {
Connection conn = null ;
PreparedStatement pstmt = null ;
ResultSet rs = null ;
public static void main(String[] args) {
new Test().showData() ;
}
public void showData(){
conn = ConnectPropertiesManager.getConn() ;
String sql = "SELECT empno,ename,sal,job FROM emp" ;
pstmt = ConnectPropertiesManager.getPrep(conn, sql) ;
try {
rs = pstmt.executeQuery() ;
while(rs.next()){
//输出查询到的所有信息
System.out.print(rs.getString(1)+" ");
System.out.print(rs.getString(2)+" ");
System.out.print(rs.getString(3)+" ");
System.out.println(rs.getString(4));
}
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally{
//在此写关闭语句的意思是：不管上面的SQL语句是否执行成功，都要关闭资源
ConnectPropertiesManager.closeAll(conn, pstmt, rs) ;
}
System.out.println("操作成功!");
}
}

　　6、输出结果如下：

7369 SMITH 800 CLERK
7499 ALLEN 1600 SALESMAN
7521 WARD 1250 SALESMAN
7566 JONES 2975 MANAGER
7654 MARTIN 1250 SALESMAN
7698 BLAKE 2850 MANAGER
7782 CLARK 2450 MANAGER
7788 SCOTT 3000 ANALYST
7839 KING 5000 PRESIDENT
7844 TURNER 1500 SALESMAN
7876 ADAMS 1100 CLERK
7900 JAMES 950 CLERK
7902 FORD 3000 ANALYST
7934 MILLER 1300 CLERK
操作成功!