package dbtest; import java.sql.Connection; import java.sql.ResultSet; import java.sql.Statement; import dbtest.DbUtil; public class SimpleDelete { public static void main(String[] args) throws Exception { Connection conn=DbUtil.getConnection(); conn.setAutoCommit(true); Statement st=null; try { st=conn.createStatement(); int n=st.executeUpdate("delete from aed_db.GoalDetail where SourceSystemId='ZA'"); System.out.println(n+ " rows has been deleted"); } catch (Exception e) { e.printStackTrace(System.out); } finally { if(st!=null) st.close(); } System.out.println("Done deletion"); } }