CSDNRGY 2017-12-01 09:24 采纳率: 87.5%
浏览 960
已采纳

如何判断我自己封装的jdbc有没有bug?

package util;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;
import java.util.ResourceBundle;

public class Jdbc {

    private static ResourceBundle res = ResourceBundle.getBundle("jdbc");
    private static String url = res.getString("db.url");
    private static String user = res.getString("db.user");
    private static String psw = res.getString("db.password");
    private static String driverClass = res.getString("driverClass");
    private static Integer poolSize = Integer.parseInt(res.getString("poolSize"));
    private static LinkedList<Connection> connections = new LinkedList<Connection>();  

    private Connection conn;
    private ResultSet rs;
    private ResultSetMetaData md;
    private PreparedStatement ps;
    private List<Map<String,Object>> list;
    private Map<String,Object> map;

    static{
        try {
            Class.forName(driverClass);
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
        initConnPool();
    }
    //初始化连接池
    private static void initConnPool() {
        for (int i = 0; i < poolSize ; i++) {
            try {
                Connection conn = DriverManager.getConnection(url, user, psw);
                connections.add(conn);
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }    
    }

    //拿出一个连接
    private synchronized void getConnection() {
        conn = connections.removeFirst();
    }

    //放回一个连接
    private synchronized void backConnection(Connection connection,PreparedStatement ps,ResultSet rs) {
        try {
            if(ps!=null) ps.close();
            if(rs!=null) rs.close();
            connections.addLast(connection);
        } catch (SQLException e) {
            e.printStackTrace();
        }

    }

    //执行数据查询语句
    public List<Map<String,Object>> dql(String sql,Object...objs){
        getConnection();
        list = new ArrayList<Map<String,Object>>();
        try {
            ps = conn.prepareStatement(sql);
            for (int i = 1; i <= objs.length; i++) {
                ps.setObject(i, objs[i]);
            }
            rs = ps.executeQuery();
            md = rs.getMetaData();
            while (rs.next()) {
                map = new HashMap<String,Object>();
                for (int i = 1; i <= md.getColumnCount(); i++) {
                    String key = md.getColumnName(i);
                    Object value = rs.getObject(i);
                    map.put(key, value);
                }
                list.add(map);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            backConnection(conn,ps,rs);
        }
        return list;
    }

    //执行数据管理语句
    public boolean dml(String sql,Object...objs){
        getConnection();
        try {
            ps = conn.prepareStatement(sql);
            for (int i = 1; i <= objs.length; i++) {
                ps.setObject(i, objs[i]);
            }
            return ps.executeUpdate()==1?true:false;
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            backConnection(conn,ps,rs);
        }
        return false;
    }

}
  • 写回答

1条回答 默认 最新

  • springcloud-zeng 2017-12-01 09:25
    关注

    用junit写一个测试类 crud都测试一遍。

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论

报告相同问题?

悬赏问题

  • ¥15 安装svn网络有问题怎么办
  • ¥15 Python爬取指定微博话题下的内容,保存为txt
  • ¥15 vue2登录调用后端接口如何实现
  • ¥65 永磁型步进电机PID算法
  • ¥15 sqlite 附加(attach database)加密数据库时,返回26是什么原因呢?
  • ¥88 找成都本地经验丰富懂小程序开发的技术大咖
  • ¥15 如何处理复杂数据表格的除法运算
  • ¥15 如何用stc8h1k08的片子做485数据透传的功能?(关键词-串口)
  • ¥15 有兄弟姐妹会用word插图功能制作类似citespace的图片吗?
  • ¥15 latex怎么处理论文引理引用参考文献