java--获取数据库连接1(单例)

应用程序直接获取链接的缺点：
用户每次请求都需要向数据库获得链接，而数据库创建连接通常需要消耗相对较大的资源，创建时间也较长。假设网站一天10万访问量，数据库服务器就需要创建10万次连接，极大的浪费数据库的资源，并且极易造成数据库服务器内存溢出、拓机。

package cn.hncu.pubs;

import java.sql.Connection;
import java.sql.DriverManager;
import java.util.Properties;

public class ConnFacory {

    public static Connection conn;
    private ConnFacory(){

    }
    static{
        try {
            Properties p=new Properties();
            p.load(ConnFacory.class.getClassLoader().getResourceAsStream("jdbc.properties"));
            String dirver=p.getProperty("driver");
            String url=p.getProperty("url");
            String name=p.getProperty("username");
            String pwd=p.getProperty("password");
            Class.forName(dirver);
            conn=DriverManager.getConnection(url, name, pwd);
            System.out.println("conn:"+conn);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    public static Connection getConnection(){
        return conn;
    }
}

jdbc.properties

##MySQL
driver=com.mysql.jdbc.Driver
url=jdbc:mysql://127.0.0.1:3306/hncu?useUnicode=true&characterEncoding=utf-8
username=root
password=1234
size=3
##Oracle
#driver=oracle.jdbc.driver.OracleDriver
#url=jdbc:oracle:thin:@127.0.0.1:1521:orcl
#username=scott
#password=tiger

演示：

package cn.hncu.tx;

import java.sql.Connection;
import java.sql.SQLException;
import java.sql.Statement;

import cn.hncu.pubs.ConnFacory;
//使用的是单例的连接工厂ConnFactory--不能使用多线程,需要创建多例
public class TxDemo {

    public static void main(String[] args) throws Exception {
        Connection con=ConnFacory.getConnection();
        Statement st = con.createStatement();

        try {
            con.setAutoCommit(false);
            st.execute("INSERT INTO person VALUES('P200','赵子龙','1')");

            new MyThread(1).start();
            new MyThread(2).start();
            new MyThread(3).start();
            new MyThread(4).start();
            new MyThread(5).start();

            Thread.sleep(1000);

            con.commit();//因为是单线程共用一个con,提交事务其他线程(用户)就不能再使用
            System.out.println("main线程提交一个事务....");
        } catch (Exception e) {
            con.rollback();
            System.out.println("main线程回滚一个事务.....");
        }finally{
//          con.setAutoCommit(true);//因为是单线程共用一个con,如果关了事物其他线程(用户)就不能使用
//          con.close();//因为是单线程共用一个con,如果关了连接其他线程(用户)就不能使用
        }

    }

}
class MyThread extends Thread{
    private int num;
    public MyThread(int num){
        this.num = num;
    }
    @Override
    public void run() {
        Connection con=ConnFacory.getConnection();
        try {
            Statement st = con.createStatement();
            con.setAutoCommit(false);
            String sql = "INSERT INTO person VALUES('P09"+num+"','赵子龙','1')";
            if(num==3){
                sql = "INSERT INTO person VALUES('P092','赵子龙','1')";
            }else{
                Thread.sleep(100);
            }
            st.executeUpdate(sql);
            con.commit();//因为是单线程共用一个con,提交事务其他线程(用户)就不能再使用
            System.out.println(num+"线程提交一个事务....");
        } catch (Exception e) {
            try {
                con.rollback();
                System.out.println(num+"线程回滚一个事务.....");
            } catch (SQLException e1) {
                e1.printStackTrace();
            }
        }finally{
//          try {
//              con.setAutoCommit(true);//因为是单线程共用一个con,如果关了事物其他线程(用户)就不能使用
//              con.close();//因为是单线程共用一个con,如果关了连接其他线程(用户)就不能使用
//          } catch (SQLException e) {
//              e.printStackTrace();
//          }
    }


    }

}