db_conn.java

程序功能：实现数据库链接。（链接oracle数据库）

程序功能：实现数据库链接。（链接oracle数据库）



package JavaBean;

import java.io.PrintWriter;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class DB_Conn {
	
	final static String driverName = "oracle.jdbc.driver.OracleDriver"; 

	private  String sourceuserName="tempt";                         //数据库用户名
	private  String sourceuserPwd="tempt";                        //密码
    final static  String sourceurl="jdbc:oracle:thin:@211.64.219.91:1521:QDKD";    //连接字符串

    private  String destuserName="tran";                         //数据库用户名
	private  String destuserPwd="tran";                        //密码
    final static  String desturl="jdbc:oracle:thin:@211.64.219.91:1521:QDKD";    //连接字符串

	/* 
    private  String destuserName="qin";                        
	private  String destuserPwd="qin";
	final static String desturl="jdbc:oracle:thin:@127.0.0.1:1521:qin1";
*/
    private  Connection conn=null;                          //数据库连接对象
    public Statement sm=null;
    //数据库语句对象
    
    
    
    
    
    
    
    private PrintWriter out = null; 
    // 建立数据库连接
    public void ConnectSourceDB(){
    	 
    	 try {
    		 Class.forName(driverName);
        	 
         } 
    	 catch(java.lang.ClassNotFoundException e) {
    		 e.printStackTrace();
    		 System.out.println("[OpenCn] 装载源数据库用户JDBC驱动出错！ ");
    	 }
    	 
         try
         {        
             conn=java.sql.DriverManager.getConnection(sourceurl,sourceuserName,sourceuserPwd);
             sm=conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
         }
         catch(Exception e)
         {
             e.printStackTrace();
             System.out.println("[OpenCn] 连接源数据库用户出错！ ");
         }

    }
    
    

    
    public void ConnectDestDB(){
      	 
      	 try {
      		 Class.forName(driverName);
          	 
           } 
      	 catch(java.lang.ClassNotFoundException e) {
      		 e.printStackTrace();
      		 System.out.println("[OpenCn] 装载目标数据库用户JDBC驱动出错！ ");
      	 }
      	 
           try
           {        
               conn=java.sql.DriverManager.getConnection(desturl,destuserName,destuserPwd);
               sm=conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);

           }
           catch(Exception e)
           {
               e.printStackTrace();
               System.out.println("[OpenCn] 连接目标数据库用户出错！ ");
           }

      }
    
    public void CloseDB(){
    	try {
			if (sm != null) {
				sm.close();
			}
			conn.close();
		} catch (SQLException SqlE) {
			SqlE.printStackTrace();
			out.print("数据库关闭失败！");
		}
    
   }
}