targetdatabase.java#1.2

来自「数据库远程同步软件NetBeans项目源文件 项目采用Jdesktop集成组件」· 2 代码 · 共 119 行

package com.qixuan.jdbc.common;

import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.Properties;

import org.apache.commons.dbcp.BasicDataSource;

/**
 * Created by IntelliJ IDEA.
 * User: Administrator
 * Date: 2008-12-10
 * Time: 11:17:01
 */
public class TargetDataBase {
	private static BasicDataSource bds ;
	private  String filePath = "conf/dbconfig_target.properties";
	private static Properties info = new Properties();
	public static final String DRIVER = "driverClass";
	public static final String URL = "url";

    public  String getFilePath() {
        return filePath;
    }

    public  void setFilePath(String filePath) {
        this.filePath = filePath;
    }

    public TargetDataBase() {
        if(bds==null){
             init();
        }
       
    }
     public TargetDataBase(String filePath) {
         this.filePath=filePath;
         if(bds==null){
             init();
        }
    }


	public static final String USER = "user";
	public static final String PWD = "password";


	//配置一个 数据源
	private void init() {
		InputStream in = null;
		try {
			//获取输入流
			in = new FileInputStream(filePath);
			info.load(in);

		} catch (IOException e) {
			in = Thread
					.currentThread()
					.getContextClassLoader()
					.getResourceAsStream(filePath);
            try {
                info.load(in);
                //e.printStackTrace();
            } catch (IOException ex) {
                e.printStackTrace();
  
            }
		} finally {
			if(in != null)
				try {
					in.close();
				} catch (IOException e) {
					e.printStackTrace();
				}
		}
		bds = new BasicDataSource();
		//一个数据源必需的几个要素：
		//驱动类名
		bds.setDriverClassName(info.getProperty(DRIVER));
		//URL
		bds.setUrl(info.getProperty(URL));
		//USER
		bds.setUsername(info.getProperty(USER));
		//PASSWD
		bds.setPassword(info.getProperty(PWD));

		//当前连接最大维护几个连接
		bds.setMaxActive(10);
		//
		bds.setMaxIdle(6);
		//最大等待时间：3秒
		bds.setMaxWait(3000);

	}


	public static Connection getConnection() {
          if(bds==null){
            new TargetDataBase();
        }
		Connection con = null;

			try {
				con = bds.getConnection();
				System.out.println(con);

			} catch (SQLException e) {
				e.printStackTrace();
			}
			return con;

	}

}