Commit fb19139b authored by Ajit Deshmukh's avatar Ajit Deshmukh

Added baselogger for the testing purpose

parent 43b99de4
...@@ -1904,20 +1904,20 @@ public class ManageSqlConf extends ActionHandlerEJB { ...@@ -1904,20 +1904,20 @@ public class ManageSqlConf extends ActionHandlerEJB {
} }
} }
BaseLogger.log("3", null, null, "dbMain:: " + dbMain + " dbRead:: " + dbRead + " dbPilot:: " + dbPilot); BaseLogger.log("3", null, null, "dbMain:: " + dbMain + " dbRead:: " + dbRead + " dbPilot:: " + dbPilot);
/* // /*
* ------------------------------- // * -------------------------------
* Get CURRENT_USER // * Get CURRENT_USER
* ------------------------------- // * -------------------------------
*/ // */
String currentUser; // String currentUser;
try (PreparedStatement ps = conn.prepareStatement("SELECT USER FROM DUAL"); // try (PreparedStatement ps = conn.prepareStatement("SELECT USER FROM DUAL");
ResultSet rs = ps.executeQuery()) { // ResultSet rs = ps.executeQuery()) {
rs.next(); // rs.next();
currentUser = rs.getString(1); // currentUser = rs.getString(1);
} // }
System.out.println("CURRENT_USER :::: " + currentUser); // System.out.println("CURRENT_USER :::: " + currentUser);
/* /*
* ------------------------------- * -------------------------------
...@@ -2343,6 +2343,14 @@ public class ManageSqlConf extends ActionHandlerEJB { ...@@ -2343,6 +2343,14 @@ public class ManageSqlConf extends ActionHandlerEJB {
logSqlExecution(tranId, enterpriseCode, "0", requestID, inputSql, 0, "E", userId, chgTerm, error, ""); logSqlExecution(tranId, enterpriseCode, "0", requestID, inputSql, 0, "E", userId, chgTerm, error, "");
} }
System.out.println(
"connForSchema USER ::: "
+ connForSchema.getMetaData().getUserName());
System.out.println(
"connForSchema URL ::: "
+ connForSchema.getMetaData().getURL());
String schemaSql = "SELECT USER FROM DUAL"; String schemaSql = "SELECT USER FROM DUAL";
PreparedStatement schemaForPs = connForSchema.prepareStatement(schemaSql); PreparedStatement schemaForPs = connForSchema.prepareStatement(schemaSql);
...@@ -2404,6 +2412,9 @@ public class ManageSqlConf extends ActionHandlerEJB { ...@@ -2404,6 +2412,9 @@ public class ManageSqlConf extends ActionHandlerEJB {
connForExecPstmt.setString(1, enterpriseCode); connForExecPstmt.setString(1, enterpriseCode);
ResultSet connForExecRs = connForExecPstmt.executeQuery(); ResultSet connForExecRs = connForExecPstmt.executeQuery();
while (connForExecRs.next()) { while (connForExecRs.next()) {
System.out.println(
"EXECUTION CONNECTION USER ::: "
+ connForExecRs.getString(1));
connForExec = connForExecRs.getString("schema_name"); connForExec = connForExecRs.getString("schema_name");
} }
...@@ -2415,6 +2426,13 @@ public class ManageSqlConf extends ActionHandlerEJB { ...@@ -2415,6 +2426,13 @@ public class ManageSqlConf extends ActionHandlerEJB {
try { try {
// Connect to the specific schema // Connect to the specific schema
connForQueryExec = connDriver.getConnectDB(connForExec); connForQueryExec = connDriver.getConnectDB(connForExec);
System.out.println(
"CONNECTED USER ::: "
+ connForQueryExec.getMetaData().getUserName());
System.out.println(
"CONNECTED URL ::: "
+ connForQueryExec.getMetaData().getURL());
} catch (Exception e) { } catch (Exception e) {
String error = (e.getMessage() != null) String error = (e.getMessage() != null)
? e.getMessage() ? e.getMessage()
...@@ -2429,6 +2447,39 @@ public class ManageSqlConf extends ActionHandlerEJB { ...@@ -2429,6 +2447,39 @@ public class ManageSqlConf extends ActionHandlerEJB {
String error = null; String error = null;
try { try {
System.out.println("\n====================");
System.out.println("FINAL EXECUTION CHECK");
System.out.println("====================");
System.out.println("schemaName ::: " + schemaName);
System.out.println("dbMainSchema ::: " + dbMainSchema);
System.out.println("connForExec ::: " + connForExec);
System.out.println(
"EXECUTION USER ::: "
+ connForQueryExec.getMetaData().getUserName());
System.out.println(
"EXECUTION URL ::: "
+ connForQueryExec.getMetaData().getURL());
PreparedStatement psCheck = connForQueryExec.prepareStatement(
"SELECT USER FROM DUAL");
ResultSet rsCheck = psCheck.executeQuery();
if (rsCheck.next()) {
System.out.println(
"SELECT USER FROM DUAL ::: "
+ rsCheck.getString(1));
}
rsCheck.close();
psCheck.close();
System.out.println("FINAL SQL ::: ");
System.out.println(finalSql);
System.out.println("====================\n");
Statement stmt = connForQueryExec.createStatement(); Statement stmt = connForQueryExec.createStatement();
if (isTrigger(finalSql) || isDdl(finalSql)) { if (isTrigger(finalSql) || isDdl(finalSql)) {
...@@ -2509,22 +2560,39 @@ public class ManageSqlConf extends ActionHandlerEJB { ...@@ -2509,22 +2560,39 @@ public class ManageSqlConf extends ActionHandlerEJB {
finalSql, updCount, "C", userId, chgTerm, null, dbMainSchema); finalSql, updCount, "C", userId, chgTerm, null, dbMainSchema);
} catch (SQLException e) { } catch (SQLException e) {
try { try {
if (connForQueryExec != null) if (connForQueryExec != null)
connForQueryExec.rollback(); connForQueryExec.rollback();
} catch (SQLException e1) { } catch (SQLException e1) {
e1.printStackTrace(); e1.printStackTrace();
} }
error = e.getMessage(); error = e.getMessage();
System.out.println("================================");
System.out.println("SQL EXECUTION FAILED");
System.out.println("Oracle Error : " + error);
System.out.println("Schema Name : " + schemaName);
System.out.println("connForExec : " + connForExec);
if (connForQueryExec != null) {
System.out.println(
"Connected User : "
+ connForQueryExec.getMetaData().getUserName());
System.out.println(
"Connected URL : "
+ connForQueryExec.getMetaData().getURL());
}
System.out.println("Failed SQL : ");
System.out.println(finalSql);
System.out.println("================================");
logSqlExecution( logSqlExecution(
tranId, enterpriseCode, linNo, requestID, tranId, enterpriseCode, linNo, requestID,
finalSql, updCount, "E", userId, chgTerm, error, dbMainSchema); finalSql, updCount, "E", userId, chgTerm, error, dbMainSchema);
// if (rethrow) {
// System.out.println("In rethrow condition");
// throw new RuntimeException(e);
// }
} finally { } finally {
if (connForExecRs != null) if (connForExecRs != null)
connForExecRs.close(); connForExecRs.close();
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment