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

* [ 1638139 ] WAN: Insert new record error

This commit is contained in:
Heng Sin Low 2007-01-18 00:31:36 +00:00
parent 5278ced530
commit cb0a1deb2d
1 changed files with 10 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
dbPort/src/org/compiere/util/DB.java
View File

@ -1022,30 +1022,24 @@ public final class DB
/** /**
* Execute Update and throw exception. * Execute Update and throw exception.
* @param SQL sql * @param sql
* @return number of rows updated or -1 if error * @return number of rows updated or -1 if error
* @param trxName transaction * @param trxName transaction
* @throws SQLException * @throws SQLException
*/ */
public static int executeUpdateEx (String SQL, String trxName) throws SQLException public static int executeUpdateEx (String sql, String trxName) throws SQLException
{ {
if (SQL == null || SQL.length() == 0) if (sql == null || sql.length() == 0)
throw new IllegalArgumentException("Required parameter missing - " + SQL); throw new IllegalArgumentException("Required parameter missing - " + sql);
// //
String sql = getDatabase().convertStatement(SQL);
int no = -1; int no = -1;
CPreparedStatement cs = new CPreparedStatement(ResultSet.TYPE_FORWARD_ONLY,
ResultSet.CONCUR_UPDATABLE, sql, trxName); // converted in call
SQLException ex = null; SQLException ex = null;
Connection conn = null;
Statement stmt = null;
try try
{ {
Trx trx = trxName == null ? null : Trx.get(trxName, true); no = cs.executeUpdate();
if (trx != null)
conn = trx.getConnection();
else
conn = DB.getConnectionRW ();
stmt = conn.createStatement();
no = stmt.executeUpdate(sql);
} }
catch (SQLException e) catch (SQLException e)
{ {
@ -1057,7 +1051,7 @@ public final class DB
// Always close cursor // Always close cursor
try try
{ {
stmt.close(); cs.close();
} }
catch (SQLException e2) catch (SQLException e2)
{ {
@ -1065,7 +1059,7 @@ public final class DB
} }
} }
if (ex != null) if (ex != null)
throw new SQLException(ex.getMessage(), ex.getSQLState(), ex.getErrorCode()); throw ex;
return no; return no;
} // execute Update } // execute Update