首页 文章

连接关闭MYSQL后不允许任何操作

提问于
浏览
1

基本上我有:

String query = "SELECT * FROM table WHERE UNIQUEID=? AND DIR IS NOT NULL AND NAME IS NOT NULL AND PAGETYPE IS NOT NULL";
DBConnect Database = new DBConnect();
Connection con = null;
PreparedStatement ps = null;
ResultSet rs=null;
try {
    con = Database.getcon();
    ps = con.prepareStatement(query);
    ps.setString(1, URI);
    rs=ps.executeQuery();
    if(rs.next()){
    }
} finally {
    if(ps != null)
        ps.close();
    if(rs != null)
        rs.close();
    if(con != null)
        con.close();
}
query = "SELECT COUNTCOMMENTS FROM videosinfos WHERE UNIQUEID=?";
try {
    con = Database.getcon();
    ps = con.prepareStatement(query); // Getting error here
    rs=ps.executeQuery();
    ps.setString(1, URI);
    rs=ps.executeQuery();
    if(rs.next()){
        comments = rs.getInt(1);
    }
} finally {
    if(ps != null)
        ps.close();
    if(rs != null)
        rs.close();
    if(con != null)
        con.close();
}

注意:我收到错误的行,对其进行评论 .

连接数据库:

public DBConnect(){
    try{
        Class.forName("com.mysql.jdbc.Driver");

        String unicode="useSSL=false&autoReconnect=true&useUnicode=yes&characterEncoding=UTF-8";
        con = DriverManager.getConnection("jdbc:mysql://localhost:15501/duckdb?"+unicode, "root", "_PWD");
        st = con.createStatement();
    }catch(Exception ex){
        System.out.println(ex.getMessage());
        System.out.println("couldn't connect!");
    }
}
public Connection getcon(){
    DBConnect condb = new DBConnect();
    Connection connect = con;
    return con;
}

但在编译中我得到这个错误:

com.mysql.jdbc.exceptions.jdbc4.MySQLNonTransientConnectionException:连接关闭后不允许任何操作 . 在sun.reflect.GeneratedConstructorAccessor18.newInstance(Unknown Source)at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)at java.lang.reflect.Constructor.newInstance(Constructor.java:423)at com.mysql.jdbc .Util.handleNewInstance(Util.java:404)位于com.mysql.jdbc.Util.getInstance(Util.java:387),位于com.mysql的com.mysql.jdbc.SQLError.createSQLException(SQLError.java:917) . com.mysql.jdbc.SQLError.createSQLException(SQLError.java:885)中的com.mysql.jdbc.SQLError.createSQLException(SQLError.java:860)中的com.mysql的jdbc.SQLError.createSQLException(SQLError.java:896) com.mysql.jdbc.ConnectionImpl.checkClosed(ConnectionImpl.java:1241)中的com.mysql.jdbc.ConnectionImpl.prepareStatement(ConnectionImpl.java:4102)处的.jdbc.ConnectionImpl.throwConnectionClosedException(ConnectionImpl.java:1246) . mys.jdbc.ConnectionImpl.prepareStatement(ConnectionImpl.java:4071)位于duck.r的duck.reg.pack.DBConnect.getitemfull_details(DBConnect.java:686) eg.pack.index.doPost(index.java:73)位于org的javax.servlet.http.HttpServlet.service(HttpServlet.java:661)javax.servlet.http.HttpServlet.service(HttpServlet.java:742) .apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:231)org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)org.apache.tomcat.websocket.server.WsFilter.doFilter (wsFilter.java:52)位于org.apache的org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) . catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:198)org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:96)at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java: 478)在org.apache.catalina.valves的org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:140) . 位于org.apache.catalina.valves.AbstractAccessLogValve.invoke(AbstractAccessLogValve.java:624)的orr.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:87)上的ErrorReportValve.invoke(ErrorReportValve.java:80) .apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:342)位于org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java)的org.apache.coyote.http11.Http11Processor.service(Http11Processor.java:799) :66)在org.apache的org.apache.coyote.AbstractProtocol $ ConnectionHandler.process(AbstractProtocol.java:868)org.apache.tomcat.util.net.NioEndpoint $ SocketProcessor.doRun(NioEndpoint.java:1455) . java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)中的tomcat.util.net.SocketProcessorBase.run(SocketProcessorBase.java:49),java.util.concurrent.ThreadPoolExecutor $ Worker.run(ThreadPoolExecutor.java: 624)atg.apache.tomcat.util.threads.TaskThread $ WrappingRunnable.run(TaskThread.java:61)at java.lang.Thread .RUN(Thread.java:748)

我正在使用Debian和MariaDB v10.x / Mysql

3 回答

  • 2

    这是因为两个原因:

    • 执行第一个 PreparedStatement 后关闭

    • getcon 使用 instance 变量而不是 local 变量 . 因此,下次调用 getcon 时,会返回相同的 conn 变量(之前关闭的变量) .

    要解决此问题,需要修改 getconDBConnect 以声明本地 conn 变量并返回它(实际上,根本不需要 DBConnect ),例如:

    public Connection getcon(){
        try{
            Class.forName("com.mysql.jdbc.Driver");
            String unicode="useSSL=false&autoReconnect=true&useUnicode=yes&characterEncoding=UTF-8";
            return DriverManager.getConnection("jdbc:mysql://localhost:15501/duckdb?"+unicode, "root", "_PWD");
        }catch(Exception ex){
            System.out.println(ex.getMessage());
            System.out.println("couldn't connect!");
            throw new RuntimeException(ex);
        }
    }
    
  • 0

    尝试改变:

    ps.close();
        rs.close();
        con.close();
    } finally {
        if(ps != null)
            ps.close();
        if(rs != null)
            rs.close();
        if(con != null)
            con.close();
    }
    

    至:

    } finally {
        if(ps != null)
            ps.close();
        if(rs != null)
            rs.close();
        if(con != null)
            con.close();
    }
    

    psrscon 两次关闭 .

  • -1

    一个好方法是使用一个try - finally块这样

    String query = "SELECT * FROM table WHERE UNIQUEID=? AND DIR IS NOT NULL AND NAME IS NOT NULL AND PAGETYPE IS NOT NULL";
            DBConnect Database = new DBConnect();
            Connection con = null;
            PreparedStatement ps = null;
            ResultSet rs=null;
            try {
                con = Database.getcon();
                ps = con.prepareStatement(query);
                ps.setString(1, URI);
                rs=ps.executeQuery();
                if(rs.next()){
                }
    
                query = "SELECT COUNTCOMMENTS FROM videosinfos WHERE UNIQUEID=?";
    
                ps = con.prepareStatement(query); // Getting error here
                rs=ps.executeQuery();
                ps.setString(1, URI);
                rs=ps.executeQuery();
                if(rs.next()){
                    comments = rs.getInt(1);
                }
            } finally {
                if(ps != null)
                    ps.close();
                if(rs != null)
                    rs.close();
                if(con != null)
                    con.close();
            }
    

相关问题