public synchronized void execute()

in old/dekaf-core/src/main/java/org/jetbrains/dekaf/jdbc/JdbcIntermediateSeance.java [97:121]

• 25 lines of code
• 5 McCabe index (conditional complexity)

  public synchronized void execute() {
    try {
      mySession.tuneStatement(myStatement, myPackLimit);
      boolean gotResultSet = myStatement.execute();
      if (gotResultSet)  {
        myDefaultResultSet = mySession.getDefaultResultSet(myStatement);
        if (!JdbcUtil.isClosed(myDefaultResultSet)) {
          mySession.tuneResultSet(myDefaultResultSet, myPackLimit);
          myDefaultResultSetHasRows = myDefaultResultSet.next();  // download first rows
          if (!myDefaultResultSetHasRows) {
            JdbcUtil.close(myDefaultResultSet); // close it if it has no rows
          }
        }
        else {
          myDefaultResultSetHasRows = false;
        }
      }
      else {
        myAffectedRowsCount = myStatement.getUpdateCount();
      }
    }
    catch (SQLException sqle) {
      throw mySession.recognizeException(sqle, myStatementText);
    }
  }