Uploaded image for project: 'JDK'
  1. JDK
  2. JDK-6310037

Number of rows are not correct in the DataBase after dataSet.Delete() then dataSet.sync().

    XMLWordPrintable

    Details

    • Type: Bug
    • Status: Closed
    • Priority: P2
    • Resolution: Fixed
    • Affects Version/s: 6
    • Fix Version/s: 6
    • Component/s: core-libs
    • Labels:
    • Subcomponent:
    • Resolved In Build:
      b53
    • CPU:
      generic
    • OS:
      generic
    • Verification:
      Verified

      Description

      JDK : jdk1.6-b46
      Platform[s] : Sol 10 sparc
      switch/Mode : Default
      DB : ORCL

      Description:
      ===========
        After the rows had been deleted from a @Query DataSet connection=false and DataSet.sync() to the DataBase, the expected rows still exits in DB.

      Test:
      =====
      java_sql_eod/column/Column003_name_004

      How to reproduce:
      ====================
      javac try_test.java
      java try_test
             
      Test output:
      =============
        
      Calling doSetup() of the Test ...
      Calling doTest() of the Test ...
      Calling QueryObjectFactory.createDefaultQueryObject()
      Got QueryObject handle
      Calling getAllPersons() :
      Got DataSet. size=3
      Queried Result: 1,Sun,Java,39
      Queried Result: 2,Java,Crazy,36
      Queried Result: 3,Easy,Java,38
      Removing the Row with this ID: 1
      Removing the Row with this ID: 2
      query size is 3
      Queried DB before sync and after delete 1,Sun,Java,39
      Queried DB before sync and after delete 2,Java,Crazy,36
      Queried DB before sync and after delete 3,Easy,Java,38
      sync() is called
      Queried DB after sync: 2,Java,Crazy,36
      Queried DB after sync: 3,Easy,Java,38
      Finished calling doSetup() of the Test

      try_test.java
      ==================
      import com.sun.rowset.CachedRowSetImpl;
      import java.io.File;
      import java.util.*;
      import java.sql.*;
      import javax.sql.rowset.*;
      import javax.sql.rowset.CachedRowSet.*;

      interface I_QueryTest extends BaseQuery {
          @Query(sql="select * from eod_column_table", readOnly=false, connected=false)
          DataSet<eod_column_dataSet> getEodColumnTable() throws SQLException;
       
           @Query(sql="select * from eod_column_table")
           DataSet<eod_column_dataSet> getAll() throws SQLException;
      }

      public class try_test {
          
          Connection conn = null;
          Statement stmt = null;
          
          private void doSetup() {

              try {
                  Class.forName("com.inet.ora.OraDriver");
              }catch (ClassNotFoundException ex) {
                  System.err.println("Exception when loading JDBC driver : "+ex);
              }
       
              try {
                  conn = DriverManager.getConnection("jdbc:inetora:[your db ip]:1521:ORCL", "user", "pass");
                  stmt = conn.createStatement();
              }catch (SQLException ex) {
                  System.err.println("Exception : "+ex);
              }
              
              try {
                  stmt.execute("delete from eod_column_table");
                  stmt.execute("drop table eod_column_table");
              }catch (SQLException sqlEx) { }

               try {
                  stmt.execute("create table eod_column_table ( id number, firstName varchar2(32), lastName varchar2(32), age int)");
                  stmt.execute("insert into eod_column_table values ( 1, 'Sun', 'Java', 39)");
                  stmt.execute("insert into eod_column_table values ( 2, 'Java', 'Crazy', 36)");
                  stmt.execute("insert into eod_column_table values ( 3, 'Easy', 'Java', 38)");
              }catch (SQLException ex) {
                  System.err.println("Exception when executing SQL :"+ex);
              }
          }

          private void doTest() {
            
              String record;
              
              boolean Status = false;
             
             try {
                 conn.close();
                 conn = DriverManager.getConnection("jdbc:inetora:[your db ip]:1521:ORCL", "user", "pass");
                 System.out.println("Calling QueryObjectFactory.createDefaultQueryObject()");
                 I_QueryTest query = QueryObjectFactory.createDefaultQueryObject(I_QueryTest.class, conn);
                 System.out.println("Got QueryObject handle ");
                 System.out.println("Calling getAllPersons() : ");
                 DataSet<eod_column_dataSet> rows = query.getEodColumnTable();
                 System.out.println("Got DataSet. size="+rows.size());
                 record = "";
                 for (eod_column_dataSet c: rows) {
                     record=c.id +"," + c.firstName +"," + c.lastName + "," + c.age;
                     System.out.println("Queried Result: " + record);
                 }
                 
                 for (eod_column_dataSet c: rows){
                     //if (c.id == 2 || c.id == 3)
                     if (c.age == 36 || c.age == 39){
                         System.out.println("Removing the Row with this ID: " + c.id);
                         rows.delete();
                     }
                 }
                 System.out.println("query size is " +rows.size());
                 record="";
                 DataSet<eod_column_dataSet> rows2 = query.getAll();
                 for (eod_column_dataSet c: rows2) {
                     record=c.id +"," + c.firstName +"," + c.lastName + "," + c.age;
                     System.out.println("Queried DB before sync and after delete " + record);
                 }
                 System.out.println("sync() is called");
                 rows.sync(conn);
                 record="";
                 rows2 = query.getAll();
                 for (eod_column_dataSet c: rows2) {
                         record=c.id +"," + c.firstName +"," + c.lastName + "," + c.age;
                         System.out.println("Queried DB after sync: " + record);
                 }
              }catch (SQLException ex){
                  System.out.println("expection: " + ex.getMessage());
              }
              //System.out.println("TEST is: " + Status);
          }
          
          public static void main(String[] args) {
              try_test qtest = new try_test();
              System.out.println("Calling doSetup() of the Test ...");
              qtest.doSetup();
              System.out.println("Calling doTest() of the Test ...");
              qtest.doTest();
              System.out.println("Finished calling doSetup() of the Test ");
          }
      }

      eod_column_dataSet.java
      ========================
      import java.sql.*;
      @Table(name="eod_column_table")

      public class eod_column_dataSet{
           int id;
           String firstName;
           String lastName;
           int age;

      }

        Attachments

          Activity

            People

            Assignee:
            skaushiksunw Shreyas Kaushik (Inactive)
            Reporter:
            tacheung Tak Wing Cheung (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            0 Start watching this issue

              Dates

              Created:
              Updated:
              Resolved:
              Imported:
              Indexed: