private void checkSchema() throws IgniteSpiException {
  try {
    U.await(initLatch);
  }
 catch (  IgniteInterruptedCheckedException e) {
    throw new IgniteSpiException("Thread has been interrupted.",e);
  }
  Connection conn=null;
  Statement stmt=null;
  try {
    conn=dataSrc.getConnection();
    conn.setTransactionIsolation(TRANSACTION_READ_COMMITTED);
    stmt=conn.createStatement();
    stmt.execute(chkQry);
  }
 catch (  SQLException e) {
    throw new IgniteSpiException("IP finder has not been properly initialized.",e);
  }
 finally {
    U.closeQuiet(stmt);
    U.closeQuiet(conn);
  }
}

private void checkSchema ( ) throws IgniteSpiException { try { U . await ( initLatch ) ; } catch ( IgniteInterruptedCheckedException e ) { throw new IgniteSpiException ( "Thread has been interrupted." , e ) ; } Connection conn = null ; Statement stmt = null ; try { conn = dataSrc . getConnection ( ) ; conn . setTransactionIsolation ( TRANSACTION_READ_COMMITTED ) ; stmt = conn . createStatement ( ) ; stmt . execute ( chkQry ) ; } catch ( SQLException e ) { throw new IgniteSpiException ( "IP finder has not been properly initialized." , e ) ; } finally { U . closeQuiet ( stmt ) ; U . closeQuiet ( conn ) ; } }
checks correctness of existing db schema .
