[teiid-issues] [JBoss JIRA] Commented: (TEIID-1627) within execution factory: hanging while executing query against same teiid instance

[Andriy Rokhmanov (JIRA)]

    [ https://issues.jboss.org/browse/TEIID-1627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=12607869#comment-12607869 ] 

Andriy Rokhmanov commented on TEIID-1627:
-----------------------------------------

The fix for TEIID-1614 resolves the problem. Thanks Steven.

> within execution factory:  hanging while executing query against same teiid instance
> ------------------------------------------------------------------------------------
>
>                 Key: TEIID-1627
>                 URL: https://issues.jboss.org/browse/TEIID-1627
>             Project: Teiid
>          Issue Type: Bug
>          Components: Query Engine
>    Affects Versions: 7.4
>            Reporter: Mark Addleman
>            Assignee: Steven Hawkins
>
> I have an execution factory that derives from TeiidExecutionFactory.  Its job is to connect to the same Teiid instance, and execute a rewritten query.  We use this to support dynamic view definitions.  Below is the createResultSetExecution method:
>     @Override
>     public ResultSetExecution createResultSetExecution(final QueryExpression command,
>                                                        final ExecutionContext executionContext,
>                                                        final RuntimeMetadata metadata,
>                                                        final Connection conn) throws TranslatorException
>     {
>         // TODO: This is not correct; this should be only called once for
>         // connection creation
>         obtainedConnection(conn);
>         return new ResultSetExecution()
>         {
>             private final List<Tuple> gatherResults = new ArrayList<Tuple>();
>             int i = 0;
>             @Override
>             public void execute() throws TranslatorException
>             {
>                 try
>                 {
>                     ViewExecutionFactory.this.logger.info("execute() start");
>                     ViewExecutionFactory.this.logger.info("before prepareStatement");
>                     final PreparedStatement prepareStatement =
>                             conn.prepareStatement("SELECT alert_id, alert_msg, lpar_id FROM demoalertdata.chorus.public.demo_alert");
>                     ViewExecutionFactory.this.logger.info("beofre executeQuery");
>                     final ResultSet resultSet = prepareStatement.executeQuery();
>                     while (resultSet.next())
>                     {
>                         this.gatherResults.add(new Tuple(resultSet));
>                     }
>                     ViewExecutionFactory.this.logger.info("before reuslt set close");
>                     resultSet.close();
>                     ViewExecutionFactory.this.logger.info("before prepare statement close");
>                     prepareStatement.close();
>                 } catch (final Exception e)
>                 {
>                     ViewExecutionFactory.this.logger.error("Error during execute", e);
>                     throw new TranslatorException(e);
>                 } finally
>                 {
>                     ViewExecutionFactory.this.logger.info("execute() end");
>                 }
>             }
>             @Override
>             public void close()
>             {
>                 //
>             }
>             @Override
>             public void cancel() throws TranslatorException
>             {
>                 //
>             }
>             @Override
>             public List<?> next() throws TranslatorException, DataNotAvailableException
>             {
>                 if (this.i < this.gatherResults.size())
>                 {
>                     final List<?> asList = this.gatherResults.get(this.i++).asList();
>                     ViewExecutionFactory.this.logger.info("RESULT " + asList);
>                     return asList;
>                 }
>                 else
>                 {
>                     return null;
>                 }
>             }
>         };
>     }
> Under 7.4, when we issue a query against this translator, the thread hangs during the executeQuery() method.  It works under 7.3.
> Not sure if it's relevant but we connect to the local Teiid instance in the getConnection() method:
>     @Override
>     synchronized final public Connection getConnection(final DataSource ds) throws TranslatorException
>     {
>         if (this.metadataInitialized)
>         {
>             final TeiidDataSource teiidDataSource = new TeiidDataSource();
>             teiidDataSource.setDatabaseName("Chorus");
>             teiidDataSource.setUser("admin");
>             teiidDataSource.setPassword("teiid");
>             try
>             {
>                 return teiidDataSource.getConnection();
>             } catch (final SQLException e)
>             {
>                 throw new TranslatorException(e);
>             }
>         }
>         else
>         {
>             return null;
>         }
>     }

--
This message is automatically generated by JIRA.
For more information on JIRA, see: http://www.atlassian.com/software/jira