cc_mamir
16 years agoNew Contributor
unable to execute update query
Hi guys,
System is in continuous running mode if trying to run update query. I tried to execute in groovy step, datasink step.
When I tried select and insert statements working fine in both groovy step and datasink steps:
following code
Try 1: groovy step
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class JDBCExample1 {
public static void main(String[] args) {
Connection con = null;
Statement stmt = null;
ResultSet rs = null;
try{
Class.forName("oracle.jdbc.driver.OracleDriver");
con = DriverManager.getConnection("connection string",
"username","password");
stmt = con.createStatement();
stmt.executeQuery("UPDATE sapient1.provider_cm_bt Set masterseq# = '11111111' where ROW_SEQ_NUM = 211956");
}
}catch(SQLException e){
e.printStackTrace();
}catch(ClassNotFoundException e){
e.printStackTrace();
}finally{
try{rs.close();}catch(Exception e){}
try{stmt.close();}catch(Exception e){}
try{con.close();}catch(Exception e){}
}
}
}
try 2: groovy step
import groovy.sql.Sql
def sql = Sql.newInstance('connection stirng','password','oracle.jdbc.driver.OracleDriver')
sql.execute("UPDATE sapient1.provider_cm_bt Set masterseq# = '11111111' where ROW_SEQ_NUM = '211956'")
Try 3: data sink:
Update sapient1.provider_cm_bt
Set masterseq# = 1000
where prov# = 'AA29437'
please help guys
Thanks and regards,
Amir
System is in continuous running mode if trying to run update query. I tried to execute in groovy step, datasink step.
When I tried select and insert statements working fine in both groovy step and datasink steps:
following code
Try 1: groovy step
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class JDBCExample1 {
public static void main(String[] args) {
Connection con = null;
Statement stmt = null;
ResultSet rs = null;
try{
Class.forName("oracle.jdbc.driver.OracleDriver");
con = DriverManager.getConnection("connection string",
"username","password");
stmt = con.createStatement();
stmt.executeQuery("UPDATE sapient1.provider_cm_bt Set masterseq# = '11111111' where ROW_SEQ_NUM = 211956");
}
}catch(SQLException e){
e.printStackTrace();
}catch(ClassNotFoundException e){
e.printStackTrace();
}finally{
try{rs.close();}catch(Exception e){}
try{stmt.close();}catch(Exception e){}
try{con.close();}catch(Exception e){}
}
}
}
try 2: groovy step
import groovy.sql.Sql
def sql = Sql.newInstance('connection stirng','password','oracle.jdbc.driver.OracleDriver')
sql.execute("UPDATE sapient1.provider_cm_bt Set masterseq# = '11111111' where ROW_SEQ_NUM = '211956'")
Try 3: data sink:
Update sapient1.provider_cm_bt
Set masterseq# = 1000
where prov# = 'AA29437'
please help guys
Thanks and regards,
Amir