Was könnten die Möglichkeiten sein, ein Thread-unsicheres java.sql.Connection-Objekt in Java zu verwenden?

Question

Ich habe es mit einem Legacy-Code zu tun, bei dem das Verbindungsobjekt in der Singleton-Dao-Klasse eine Member-Variable ist und anfällig für Rennbedingungen ist.

Ich weiß, dass dies ein potenzielles Designproblem ist, aber ich bin daran interessiert, über die verschiedenen Arten von Problemen zu wissen, die man sich beim Umgang mit dem jdbc-Verbindungsobjekt in Java vorstellen kann.

Es folgt der EventLoggerDAO Klassencode:

package com.code.ref.dao; 

import java.sql.Connection; 
import java.sql.PreparedStatement; 

import com.code.ref.utils.common.DBUtil; 
import com.code.ref.utils.common.PCMLLogger; 

public class EventLoggerDAO { 

private static EventLoggerDAO staticobj_EventLoggerDAO; 

private Connection obj_ClsConnection; 

private PreparedStatement obj_ClsPreparedStmt; 

private EventLoggerDAO() { 
    try { 
    obj_ClsConnection = DBUtil.getConnection(); 
    } catch (Exception e) { 
    PCMLLogger.logMessage(EventLoggerDAO.class, "EventLoggerDAO()", "Some problem in creating db connection:" + e); 
    } 
} 

public static synchronized EventLoggerDAO getInstance() { 
    if (staticobj_EventLoggerDAO == null) { 
    synchronized (EventLoggerDAO.class) { 
    if (staticobj_EventLoggerDAO == null) 
    staticobj_EventLoggerDAO = new EventLoggerDAO(); 
    } 
    } 
    return staticobj_EventLoggerDAO; 
} 

public void addEvent(String sName, String sType, String sAction, String sModifiedBy) throws Exception { 
    StringBuffer sbQuery = new StringBuffer(); 
    sbQuery.append("INSERT INTO TM_EVENT_LOG (NAME, TYPE, ACTION, MODIFIED_BY) ").append("VALUES (?, ?, ?, ?) "); 
    if(obj_ClsConnection == null) 
    obj_ClsConnection = DBUtil.getConnection(); 

    obj_ClsPreparedStmt = obj_ClsConnection.prepareStatement(sbQuery.toString()); 
    obj_ClsPreparedStmt.setString(1, sName); 
    obj_ClsPreparedStmt.setString(2, sType); 
    obj_ClsPreparedStmt.setString(3, sAction); 
    obj_ClsPreparedStmt.setString(4, sModifiedBy); 
    obj_ClsPreparedStmt.executeUpdate(); 
    if (obj_ClsPreparedStmt != null) { 
    obj_ClsPreparedStmt.close(); 
    obj_ClsPreparedStmt = null; 
    } 
    } 
} 

Problem beobachtet:

Manchmal kommt es vor, dass die Tabelle TM_EVENT_LOG stoppt das Einfügen und es gibt nicht einmal Ausnahme in den Server-Logs.

Ich vermute, dass die Verbindungsobjekte, die von verschiedenen Threads gehalten werden, unter Wettbewerbsbedingungen möglicherweise zu einem inkonsistenten Zustand führen und die Daten möglicherweise nicht übertragen. Die Verbindung wird über eine Websphere-Datenquelle abgeleitet, die einen Verbindungspool verwaltet.

Irgendwelche Gedanken oder Ideen, warum dies passieren könnte?

Answer 1

Hier kann alles passieren. Beachten Sie, dass obj_ClsPreparedStmt eine Membervariable ist, während es als eine lokale Variable verwendet wird - es scheint ein viel ernsthafteres Problem zu sein als Connection.