java - 在java中为轮询程序建立数据库连接的最佳方法是什么

Question

我正在使用 TimerTask 在 java 中创建一个轮询程序，用于自动发送电子邮件和其他通知。现在，该程序每秒检查数据库中是否有任何可用的新数据。

现在我正在创建如下所示的连接

连接器类保存数据库详细信息并返回连接。

public class Connector implements Serializable {

    private static final long serialVersionUID = 1L;
    private ResourceBundle prop = ResourceBundle.getBundle("dbdetails");

    public Connection getConnection() throws Exception {
        Connection con;
        Class.forName((String) prop.getString("DB_DRIVER"));
        con = DriverManager.getConnection((String) prop.getString("DB_URL"),
                (String) prop.getString("DB_USER"),
                (String) prop.getString("DB_PASS"));
        return con;

    }

}

我的投票类

public class EmailPoller extends TimerTask {
    private static Logger logger = Logger.getLogger(EmailPoller.class);
    private Connector connector = new Connector();

    @Override
    public void run() {
        Connection con = null;
        PreparedStatement ps = null, ps1 = null;
        ResultSet rs = null;
        try {
            con = connector.getConnection();
            ps = con.prepareStatement("select to_addr,subject,content,id from email_notification where status='A'");
            ps1 = con
                    .prepareStatement("update email_notification set status='I' where id=?");
            rs = ps.executeQuery();
            while (rs.next()) {
                Boolean b = Mailer.sendMail(rs.getString(1), rs.getString(2),
                        rs.getString(3));

                if (b) {
                    ps1.setInt(1, rs.getInt(4));
                    ps1.executeUpdate();
                }
            }
        } catch (Exception ex) {
            logger.info("Email Poller Error : " + ex);
        } finally {
            try {
                if (rs != null) {
                    rs.close();
                }
                if (ps != null) {
                    ps.close();
                }
                if (ps1 != null) {
                    ps1.close();
                }
                if (con != null) {
                    con.close();
                }

            } catch (Exception ex) {
                logger.info("Email Poller Error : " + ex);
            }
        }
    }
}

发送电子邮件后，我正在更新标志。 Mailer 正在完美发送邮件。

这是否是检查数据库数据的正确方法，或者有其他连接数据库的最佳方法吗？

Answer 1

由于您需要在特定时间段轮询数据库， - 每次在数据库中查找内容时都不应该创建连接。创建连接一次并重用它，或者让DataSource处理一切。您只需向 DataSource 请求一个连接，它就会为您提供一个连接。

您可以稍微修改您的 Connector 类，如下所示，以允许数据源实现处理连接池。

下面的示例使用DataSource 接口(interface)的MySql 实现。不过，您可以根据您使用的数据库来更改实现，只需将相应的 jar 添加到您的类路径即可。

    class Connector implements Serializable {

    private static final long serialVersionUID = 1L;
    private static ResourceBundle prop = ResourceBundle.getBundle("dbdetails");
    private static MysqlDataSource dataSource = null;

    // Dont allow any instance of this class
    private Connector(){
    }

    private static void initDataSource()
    {
        try 
        {
            dataSource = new MysqlDataSource();
            dataSource.setURL(prop.getString("DB_URL"));
            dataSource.setUser(prop.getString("DB_USER"));
            dataSource.setPassword(prop.getString("DB_PASS"));
        } 
        catch (SQLException e) {
            // handle the Exception according to your application demand
        }
    } 
    /*
     * Return a connection from the datasource pool 
     */
    public static Connection getConnection() throws Exception {
       if(dataSource == null)
       {
           initDataSource();
       }
       return dataSource.getConnection();
    }

}

虽然上面的方法变得更加高效，但它更适合需要处理大量请求并池化连接的Web应用程序。由于您的程序是独立代码，因此您可以忽略连接池，只需确保您的应用程序在任何时候只有一个连接即可。您可以修改 Connector 类，如下所示:

class Connector implements Serializable {

private static final long serialVersionUID = 1L;
private static ResourceBundle prop = ResourceBundle.getBundle("dbdetails");;
private static Connection con = null;

// Dont allow any instance to be created for this class
private Connector(){
}

private static void initConnection() throws  Exception
{
    Class.forName((String) prop.getString("DB_DRIVER"));
    con = DriverManager.getConnection((String) prop.getString("DB_URL"),
            (String) prop.getString("DB_USER"),
            (String) prop.getString("DB_PASS"));
}

public static Connection getConnection() throws Exception {
    if(con == null)
    {
        initConnection();
    }
    return con;
}

}

获取连接为:Connector.getConnection()，遵循单例模式。