如何在 try-catch 块中重新连接到数据库

Question

我有一个Java应用程序，它使用Spring JDBCTemplate执行连续不间断的快速插入MySQL数据库。 几分钟后，显然数据库上发生了一些中断数据库连接的事情，我得到了一个异常

org.springframework.jdbc.CannotGetJdbcConnectionException: Could not get JDBC Connection; nested exception is com.mysql.jdbc.exceptions.jdbc4.CommunicationsException: Communications link failure

我能够在代码中捕获 SQLException，因此此时我想重新建立数据库连接并退出 catch 块并继续。

实现

此目的的方法是什么？

编辑：这是捕获异常的方法：

public int insertRecord(final String sql,final Object[] paramArray, KeyHolder keyHolder) {
        Integer retStatus = jdbcTemplate.update(new PreparedStatementCreator() { 
            public PreparedStatement createPreparedStatement(Connection con) { 
                    String[] keyColNames=new String[1];
                    PreparedStatement ps = null;
                    try {
                        ps=con.prepareStatement(sql,keyColNames); 
                        if(paramArray!=null){
                            int size=paramArray.length;
                            for(int i=0;i<size;i++){
                                ps.setObject(i+1, paramArray[i]);
                            }
                        }
                    } catch (CannotGetJdbcConnectionException e) {
                        logger.debug("caught SQLexception, now what should I do?");
                        con.reconnectToDatabase();  // this method doesnt exist but is what I need!
                    }
                    return ps; 
                } 
            }, keyHolder);  
        return retStatus;
    }

Answer 1

更新：

如果您希望简单地重新连接数据库，则可以专门为此创建一个类，为其创建一个getConnection方法，然后简单地返回重新建立的连接。例如：

public class ConnectionManager {
private Connection connection;
public String driverURL = "[Your driver URL]";
    public Connection getConnection(String user, String password) {
    try {
        //SQLServerDriver or whichever you are using
        Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
        connection = DriverManager.getConnection(driverURL, username, password);
    }catch(ClassNotFoundException e) {
        e.printStackTrace();
    }
    catch(SQLException e) {
        e.printStackTrace();
    }
    return connection;
}

然后：

con = new ConnectionManager().getConnection(user, pass);

从那里您可以再次调用该方法并重试插入或随心所欲地进行操作。