midsuit
/
core-jgi
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

* part of fix for bug [1619933]

This commit is contained in:
Heng Sin Low 2007-01-05 13:04:25 +00:00
parent 6d9d26be64
commit 42d16ef526
3 changed files with 25 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
dbPort/src/org/compiere/util/CPreparedStatement.java
View File

@ -52,6 +52,8 @@ public class CPreparedStatement extends CStatement implements PreparedStatement
p_vo = new CStatementVO (resultSetType, resultSetConcurrency, p_vo = new CStatementVO (resultSetType, resultSetConcurrency,
DB.getDatabase().convertStatement(sql0)); DB.getDatabase().convertStatement(sql0));
p_vo.setTrxName(trxName);
// Local access // Local access
if (!DB.isRemoteObjects()) if (!DB.isRemoteObjects())
{ {
@ -972,7 +974,7 @@ public class CPreparedStatement extends CStatement implements PreparedStatement
// return null; // return null;
**/ **/
// shared connection // shared connection
Connection conn = local_getConnection (null); Connection conn = local_getConnection (p_vo.getTrxName());
PreparedStatement pstmt = null; PreparedStatement pstmt = null;
RowSet rowSet = null; RowSet rowSet = null;
try try
@ -1054,7 +1056,7 @@ public class CPreparedStatement extends CStatement implements PreparedStatement
if (db == null) if (db == null)
throw new NullPointerException("Remote - No Database"); throw new NullPointerException("Remote - No Database");
// //
PreparedStatement pstmt = local_getPreparedStatement (false, null); // shared connection PreparedStatement pstmt = local_getPreparedStatement (false, p_vo.getTrxName());
int result = pstmt.executeUpdate(); int result = pstmt.executeUpdate();
pstmt.close(); pstmt.close();
// //

4
dbPort/src/org/compiere/util/CStatement.java
View File

@ -723,7 +723,7 @@ public class CStatement implements Statement
if (db == null) if (db == null)
throw new NullPointerException("Remote - No Database"); throw new NullPointerException("Remote - No Database");
// //
Statement pstmt = local_getStatement (false, null); // shared connection Statement pstmt = local_getStatement (false, p_vo.getTrxName());
int result = pstmt.executeUpdate(p_vo.getSql()); int result = pstmt.executeUpdate(p_vo.getSql());
pstmt.close(); pstmt.close();
// //
@ -838,7 +838,7 @@ public class CStatement implements Statement
// return null; // return null;
**/ **/
// Shared Connection // Shared Connection
Connection conn = local_getConnection (null); Connection conn = local_getConnection (p_vo.getTrxName());
PreparedStatement pstmt = null; PreparedStatement pstmt = null;
RowSet rowSet = null; RowSet rowSet = null;
try try

19
dbPort/src/org/compiere/util/CStatementVO.java
View File

@ -61,6 +61,8 @@ public class CStatementVO implements Serializable
private String m_sql; private String m_sql;
/** Parameters */ /** Parameters */
private ArrayList<Object> m_parameters = new ArrayList<Object>(); private ArrayList<Object> m_parameters = new ArrayList<Object>();
/** Transaction Name **/
private String m_trxName = null;
/** /**
* String representation * String representation
@ -191,5 +193,22 @@ public class CStatementVO implements Serializable
{ {
m_resultSetConcurrency = resultSetConcurrency; m_resultSetConcurrency = resultSetConcurrency;
} }
/**
* @return transaction name
*/
public String getTrxName()
{
return m_trxName;
}
/**
* Set transaction name
* @param trxName
*/
public void setTrxName(String trxName)
{
m_trxName = trxName;
}
} // CStatementVO } // CStatementVO