[teiid-issues] [JBoss JIRA] (TEIID-3998) EDS 5.3 jdbc driver virtual procedure call against JDV 6.2.3

[Filip Elias (JIRA)]

Filip Elias created TEIID-3998:
----------------------------------

             Summary: EDS 5.3 jdbc driver virtual procedure call against JDV 6.2.3
                 Key: TEIID-3998
                 URL: https://issues.jboss.org/browse/TEIID-3998
             Project: Teiid
          Issue Type: Bug
    Affects Versions: 8.12
         Environment: eds-5.3.1_1_2015-jdbc
            Reporter: Filip Elias
            Assignee: Steven Hawkins


We identified an issue when trying to connect with EDS 5.3 jdbc driver to JDV 6.2.3 instance.
The problem is caused by virtual procedure execution.
Query performed:
EXEC View.hiddenUpdate(456,'changed')
View definition:
{code}
<model name="View" type="VIRTUAL">
   <metadata type="DDL"><![CDATA[
	CREATE VIRTUAL PROCEDURE hiddenUpdate(ID integer,CUSTOMERNAME string) AS BEGIN
   MERGE INTO Customers(id,customername) VALUES(ID,CUSTOMERNAME);
END
]]> </metadata>
</model>
{code}
NPE excepton:
{code}
Exception in thread "main" java.lang.NullPointerException
	at org.teiid.jdbc.StatementImpl.executeUpdate(StatementImpl.java:342)
	at jdbcdriver.JDBCClient.executeUpdate(JDBCClient.java:59)
	at jdbcdriver.JDBCClient.main(JDBCClient.java:52)
{code}

Client code:
{code}
    @Test
    public void procedureInvalidateCacheTest(){
        String sqlSelectAll = "/*+ cache */SELECT * FROM Customers;";
        try{
            
            Utils.executeUpdate(con,"INSERT INTO Customers(id,customername) VALUES (456, 'Testing 1');");
            
            ResultSet empty = Utils.executeQuery(con, sqlSelectAll);
            Assert.assertTrue(empty.next(), "ResultSet should be empty");
            
            try{
                Thread.sleep(3000);
            }catch(InterruptedException ie){
                
            } 
            
            Utils.executeUpdate(con,"EXEC View.hiddenUpdate(456,'changed')");
          
            ResultSet full = Utils.executeQuery(con, sqlSelectAll);
            Assert.assertTrue(full.next(), "ResultSet shouldn't be empty");
            
            int custId = full.getInt(1);
            String custName = full.getString(2);
            Assert.assertEquals(custId, 456,"Returned row with wrong customer id");
            Assert.assertEquals(custName,"changed","PROCEDURE with UPDATE query didn't invalidate the cache:returned row with wrong customer name");
            
            
        }catch(SQLException se){
            LOG.error("Error during performing sql query on teiid",se);
            Assert.fail("Error during performing sql query on teiid", se);
        }
    }

    static Connection getTeiidConnectionUser1() throws SQLException {
        LOG.info("Getting Teiid connection for user1.");
        return TeiidDriver.getInstance().connect(TEIID_URL_USER1, null);
    }

    static int executeUpdate(Connection con, String sql) throws SQLException{
        LOG.info("Executing update [connection: " + con + "]: " + sql + ".");
        Statement s = con.createStatement();
        return s.executeUpdate(sql);
    }
{code}

Server log is in the attachment.



--
This message was sent by Atlassian JIRA
(v6.4.11#64026)