首页 > 程序开发 > 软件开发 > 其他 >

Java Web开发Java篇(12)使用连接池的MySQL操作类

2017-02-16

Java Web开发Java篇(12)使用连接池的MySQL操作类:前面我们演示了一个简单的数据库连接池,我们再结合之前的mysql数据库操作类MysqlHandler修改一下,实现一个使用连接池的mysql操作类。

Java Web开发Java篇(12)使用连接池的MySQL操作类:前面我们演示了一个简单的数据库连接池,我们再结合之前的mysql数据库操作类MysqlHandler修改一下,实现一个使用连接池的mysql操作类。

首先,我们先得有一个自定义的异常类,猫哥主要想用它演示下抛出特定异常。

package sql;//Java中的类可以用不同的package(包)划分,这样更加条理
public class MysqlException extends Exception{//自定义异常类,因为继承了Exception类,所以成为了异常家族的一员
    public MysqlException(String msg){//构造函数,包含一条消息,此处我们简单的以消息内容区分不同的数据库异常
        super(msg);
    }
}

注意本篇中所有的类都是在package sql下的,也就是在包sql下。如果把类比做文件,那包就是文件夹——整理类的作用,如此而已。

OK,然后我们稍微改造下我们的数据库连接池类如下:

package sql;

import java.sql.*;//这个java.sql和上面自定义的sql是一回事。名字都不一样嘛,一个叫java.sql一个叫sql。就像李老四和李四是两个人名。
import java.util.LinkedList;
public class MysqlPool {
    //使用static保证全局共享一个池子,使用LinkedList是因为经常删除、添加元素
    private static LinkedList pool = new LinkedList(); 
    //最大连接数
    private static int maxCount=20;

    static{//此处修改为使用静态代码块实现数据库连接池初始化,注意静态代码块中的语句只会执行一次,且在类初始化时候执行
        //下面的代码无需捕获异常,因为准备在MysqlHandler中捕获数据库异常
        for(int i=0;i

需要注意两点:1是静态代码块的使用,让整个程序不用再管理数据库连接池的初始化问题,相对于手工init()初始化所有连接,静态代码块在MysqlPool类第一次加载时自动调用显得更加的牛X。2是注意我们使用MysqlHandler 的buildConnection方法拿到连接,这个方法没有什么变化,也没有变化的必要,就是建立一个数据库连接。

OK,再来看我们封装的操作类:

package sql;
import java.sql.*;//导入数据库相关类库
/**
 * MysqlHandler MySQL数据库管理类,使用数据库连接池
 * @author 猫哥
 * @date 2016.1.9
 */
public class MysqlHandler{   
    //依然是那熟悉的三个必备参数
    private Connection conn = null;
    private Statement stmt = null;
    private ResultSet rs = null;
    //建立数据库连接,此处仅用于提供原始连接,供放入池中使用
    public Connection buildConnection() {        
         String driver = "com.mysql.jdbc.Driver";//MySQL数据库的驱动程序名
         String url = "jdbc:mysql://localhost:3306/java?useUnicode=true&characterEncoding=utf-8";//数据库连接字符串
         String user = "root";//用户名
         String password = "Pass1234";//密码
         try{   
            Class.forName(driver);//加载驱动程序
            conn=DriverManager.getConnection(url,user,password);//输入必备参数,获取连接   
         }
         catch(Exception ex){
             ex.printStackTrace();//可以输出比较详细的异常信息 
         }
        return conn;
    }
    //操作1,“增删改查”中,增、删、改都是执行sql语句,无需返回ResultSet结果集,所以设置为一个方法
    public int execute(String sql){
        try {
            conn=MysqlPool.getConnecton();//用时从池中取,很爽快
            stmt=conn.createStatement();
            int affectedCount = stmt.executeUpdate(sql);//此处真正执行stmt定义的操作
            return affectedCount;//这个是收到影响的行数
        }
        catch(MysqlException myEx){//可以针对自定义的异常单独处理
            myEx.printStackTrace();
            return -2;//返回-2,表示数据库连接池分配超限,可以在外面针对性处理,其实可以直接抛到更外层处理,还是看程序员决策了
        }
        catch (Exception ex) {
            ex.printStackTrace();
            return -1;//返回-1,表示执行失败了,有异常
        }
    }
    //操作2,如果是查询,需返回结果集
    public ResultSet query(String sql)throws Exception{
        try{
            conn=MysqlPool.getConnecton();//用时从池中取,很爽快
            stmt=conn.createStatement();
            rs = stmt.executeQuery(sql);//执行pstmt中定义的查询
            return rs;//将结果集返回 
        }
        catch(MysqlException myEx){//可以针对自定义的异常单独处理
            throw new MysqlException(myEx.getMessage());//还可以往外抛,可以针对查询时数据库连接池连接不足问题单独处理(例如延迟响应用户请求以下)
        }catch(Exception ex){
             ex.printStackTrace();
            return null;
        }
    }
    //操作3,释放资源
    public void sayGoodbye(){
        //此处注意,conn在池中管理,此处无需关闭
        if(rs!=null){//关闭结果集,这个不关闭也浪费
            try {
                rs.close();
            } catch (Exception ex) {
                ex.printStackTrace();
            }
        }
        if(stmt!=null){//关闭Statement,不要浪费
            try {
                stmt.close();
            } catch (Exception ex) {
                ex.printStackTrace();
            }
        }
    MysqlPool.release(conn);
    }

}
OK,最后,单独写一个测试类,测试以下: package sql; import java.sql.*; public class SqlTest { public static void main(String[] args) throws Exception {//此处我们不处理异常 // TODO Auto-generated method stub MysqlHandler hand=new MysqlHandler(); ResultSet rs=null;//可以使用多次 //查 rs=hand.query("select * from student_info"); //展示结果 System.out.println("\n查询结果如下:"); while(rs.next()){ System.out.print(rs.getInt(1) + "|"); System.out.print(rs.getString(2) + "\t"); } //增加2个 int addCount=hand.execute("insert into student_info (student_name) values('火星人'),('水星人')"); System.out.println("\n增加了"+addCount+"个"); //删除一个 int delCount=hand.execute("delete from student_info where student_name='张三'"); System.out.println("\n删除了"+delCount+"个"); //修改一个,把李四改造成火星人 int changeCount=hand.execute("update student_info set student_name='火星人李四' where student_name='李四'"); System.out.println("\n修改了"+changeCount+"个"); //查 rs=hand.query("select * from student_info"); System.out.println("\n查询结果如下:"); while(rs.next()){ System.out.print(rs.getInt(1) + "|"); System.out.print(rs.getString(2) + "\t"); } hand.sayGoodbye(); } }
相关文章
最新文章
热点推荐