baidu_28379135
baidu_28379135
采纳率100%
2015-07-22 08:28 阅读 2.8k
已采纳

java中多线程下静态connection的问题

普遍观点是不要使用静态的连接,但是……我面临的需求情况是1.数据只查不改2.该连接只在用户登陆时使用,而其他过程有单独的连接池(与登录不是一个库),用池
觉得浪费3.可能在同一时间有几千人同时登陆,而一天内的其他时间登录次数很少。
以下是部分代码:

 public class CWJdbcConnection {
    private static Map<String, String> map = new GetFile().getFile(
            "FcgDriverClassName", "FcgIp", "FcgName", "FcgPasswd");//获取连接信息
    private static int flag = 0;
    private static Connection conn;
    private PreparedStatement ps = null;
    private boolean isClosed = false;

    static {
        try {
            Class.forName(map.get("fcgDriverClassName"));
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
    }

    public CWJdbcConnection() {
        CWJdbcConnection.doConnection(1);
    }

    public ResultSet doSql(String sql) {
        if (conn == null)
            try {
                conn = DriverManager.getConnection(map.get("fcgIp").toString(),
                        map.get("fcgName").toString(), map.get("fcgPasswd")
                                .toString());
            } catch (SQLException e) {
                e.printStackTrace();
            }
        try {
            ps = conn.prepareStatement(sql);
            return ps.executeQuery();
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return null;
    }

    public void close() {
        if (isClosed)
            return;
        if (ps != null)
            try {
                ps.close();
            } catch (SQLException e) {
            }
        isClosed = true;
        CWJdbcConnection.doConnection(-1);
    }

    private synchronized static void doConnection(int a) {
        flag += a;
        if (flag < 0)
            flag = flag / 0;//不要嘲笑我……
        if (flag == 0 && conn != null) {
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
            conn = null;
        }
    }
}

使用方法是:

CWJdbcConnection cw = new CWJdbcConnection();
ResultSet   rs = cw.doSql(sql);
doRS(rs);//进行操作
cw.close();

我在这里向大家请教的是:这个类在并发的情况下会出现什么问题?
PS:在手头没有测试工具和不熟悉程序测试的情况下,我仅仅是开了100个线程,让它们并发读数据,暂时没发现问题,线程全部结束后Connection也都关闭了。但是我不放心啊!!

  • 点赞
  • 写回答
  • 关注问题
  • 收藏
  • 复制链接分享

4条回答 默认 最新

  • 已采纳
    danielinbiti danielinbiti 2015-07-22 08:37
     public ResultSet doSql(String sql) {
            if (conn == null)
                try {//这里并发的时候可能会进入不止1次,对conn初始化进行加锁,这单例初始化很常见,一搜一堆。
                    conn = DriverManager.getConnection(map.get("fcgIp").toString(),
                            map.get("fcgName").toString(), map.get("fcgPasswd")
                                    .toString());
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            try {
                ps = conn.prepareStatement(sql);
                return ps.executeQuery();
            } catch (SQLException e) {
                e.printStackTrace();
            }
            return null;
        }
    
    点赞 1 评论 复制链接分享
  • baidu_28379135 baidu_28379135 2015-07-22 08:40

    确实是这样。我竟然犯了这种错误…………
    加锁是不行的,是不是有其他方法呢?

    点赞 评论 复制链接分享
  • oyljerry oyljerry 2015-07-22 08:50

    单独搞一个数据库连接类,它内部用数据库连接池等,其他线程有数据库查询等,都把数据放到一个队列等,有这个数据库类统一处理,并返回结果等。这样就不需要每个线程都进行数据库操作

    点赞 评论 复制链接分享
  • sina_2831808769 sina_2831808769 2015-07-25 05:54

    public ResultSet doSql(String sql) {
    if (conn == null)
    try {//这里并发的时候可能会进入不止1次,对conn初始化进行加锁,这单例初始化很常见,一搜一堆。
    conn = DriverManager.getConnection(map.get("fcgIp").toString(),
    map.get("fcgName").toString(), map.get("fcgPasswd")
    .toString());
    } catch (SQLException e) {
    e.printStackTrace();
    }
    try {
    ps = conn.prepareStatement(sql);
    return ps.executeQuery();
    } catch (SQLException e) {
    e.printStackTrace();
    }
    return null;
    }

    点赞 评论 复制链接分享

相关推荐