Meilleures pratiques pour la connexion Java?

Après marre avec c3p0 constante de verrouillage de je suis passant à BoneCP pour une connexion de remplacement de la piscine pour ma base de données. J'ai un serveur d'application qui traite autour de 7 000 articles par minute et doit consigner ces éléments dans notre base de données MySQL. J'ai actuellement 100 threads de travail et de créer mon bassin comme tels:

BoneCPConfig config = new BoneCPConfig();
      config.setJdbcUrl("jdbc:mysql://"+Settings.MYSQL_HOSTNAME+"/"+Settings.MYSQL_DATABASE+"?autoReconnectForPools=true" ); 
      config.setUsername(Settings.MYSQL_USERNAME); 
      config.setPassword(Settings.MYSQL_PASSWORD);
      config.setMinConnectionsPerPartition(5);
      config.setMaxConnectionsPerPartition(10);
      config.setPartitionCount(5);
      config.setAcquireIncrement(5);
      connectionPool = new BoneCP(config); //setup the connection pool

Sont ceux qui sont acceptables des paramètres pour une telle application? Je demande parce que, après une minute ou deux en cours d'exécution, je recevais BoneCP exceptions lorsque vous essayez d'appeler getConnection sur la piscine. Merci pour l'aide.

Voici le code que j'utilisais pour la db appels dans mon threads de travail, il ne peut pas échouer sur la dbConn = this.dbPool.getConnection() ligne. Je ne suis pas fermer les connexions correctement?

private void insertIntoDb() {
    try {  
        Connection dbConn = this.dbPool.getConnection();

        try {
            PreparedStatement ps3 = dbConn.prepareStatement("INSERT IGNORE INTO test_table1 SET test1=?, test2=?, test3=?");
            ps3.setString(1, "some string");
            ps3.setString(2, "some other string");
            ps3.setString(3, "more strings");
            ps3.execute();
            ps3.close();

            PreparedStatement ps4 = dbConn.prepareStatement("INSERT IGNORE INTO test_table2 SET test1=?, test2=?, test3=?");
            ps4.setString(1, "some string");
            ps4.setString(2, "some other string");
            ps4.setString(3, "more strings");
            ps4.execute();
            ps4.close();

        } catch(SQLException e) {
            logger.error(e.getMessage());
        } finally {
            try {
                dbConn.close();
            } catch (SQLException e) {
                logger.error(e.getMessage());
            }
        }
    } catch(SQLException e) {
        logger.error(e.getMessage());
    }
}

C'est l'erreur que j'ai été voir:

 [java]  WARN [com.google.common.base.internal.Finalizer] (ConnectionPartition.java:141) - BoneCP detected an unclosed connection and will now attempt to close it for you. You should be closing this connection in your application - enable connectionWatch for additional debugging assistance.
[java]  WARN [com.google.common.base.internal.Finalizer] (ConnectionPartition.java:141) - BoneCP detected an unclosed connection and will now attempt to close it for you. You should be closing this connection in your application - enable connectionWatch for additional debugging assistance.
[java]  WARN [com.google.common.base.internal.Finalizer] (ConnectionPartition.java:141) - BoneCP detected an unclosed connection and will now attempt to close it for you. You should be closing this connection in your application - enable connectionWatch for additional debugging assistance.
[java]  WARN [com.google.common.base.internal.Finalizer] (ConnectionPartition.java:141) - BoneCP detected an unclosed connection and will now attempt to close it for you. You should be closing this connection in your application - enable connectionWatch for additional debugging assistance.
[java]  WARN [com.google.common.base.internal.Finalizer] (ConnectionPartition.java:141) - BoneCP detected an unclosed connection and will now attempt to close it for you. You should be closing this connection in your application - enable connectionWatch for additional debugging assistance.
[java]  WARN [com.google.common.base.internal.Finalizer] (ConnectionPartition.java:141) - BoneCP detected an unclosed connection and will now attempt to close it for you. You should be closing this connection in your application - enable connectionWatch for additional debugging assistance.
[java]  WARN [com.google.common.base.internal.Finalizer] (ConnectionPartition.java:141) - BoneCP detected an unclosed connection and will now attempt to close it for you. You should be closing this connection in your application - enable connectionWatch for additional debugging assistance.
ERROR pool-2-thread-39 2010-09-04 13:36:19,798 com.test.testpackage.MyTask - null
java.sql.SQLException
at com.jolbox.bonecp.BoneCP.getConnection(BoneCP.java:381)

source d'informationauteur James

  1. 15

    Sont ceux qui sont acceptables des paramètres pour une telle application? Je demande parce que, après une minute ou deux en cours d'exécution, je recevais boneCP exceptions lorsque vous essayez d'appeler getConnection sur la piscine. merci pour l'aide.

    Si vous disposez de 100 travailleurs, pourquoi ne vous limitez la piscine à 50 connexions (nombre de partitions de x le nombre maximum de connexions par partition à savoir 5 x 10, dans votre cas)?

    Je ne suis pas fermer les connexions correctement?

    Semble ok (mais peut-être permettre connectionWatch comme évoqué pour voir ce que l'avertissement est exactement). Personnellement, je ferme toutes les ressources que j'utilise, y compris les relevés et les jeux de résultats. Juste au cas où, voici le langage que j'utilise:

    Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
try {
conn = pool.getConnection();
pstmt = conn.prepareStatement(SOME_SQL);
pstmt.setFoo(1, foo);
...
rs = pstmt.executeQuery();
...
} finally {
if (rs != null) try { rs.close(); } catch (SQLException quiet) {}
if (pstmt != null) try { pstmt.close(); } catch (SQLException quiet) {}
if (conn != null) try { conn.close(); } catch (SQLException quiet) {}
}

    Vous pourriez groupe ci-dessus appels à une méthode statique d'une classe utilitaire.

    Ou vous pouvez utiliser DbUnit.closeQuietly(Connexion, une Déclaration, un ResultSet) de Commons DbUtils qui fait déjà cela.