public void executeQueries ( List < String > queries , Optional < String > proxy ) throws SQLException { Preconditions . checkArgument ( ! this . statementMap . isEmpty ( ) , "No hive connection. Unable to execute queries" ) ; if ( ! proxy . isPresent ( ) ) { Preconditions . checkArgument ( this . statementMap . size ( ) == 1 , "Multiple Hive connections. Please specify a user" ) ; proxy = Optional . fromNullable ( this . statementMap . keySet ( ) . iterator ( ) . next ( ) ) ; } Statement statement = this . statementMap . get ( proxy . get ( ) ) ; for ( String query : queries ) { statement . execute ( query ) ; } }
Execute queries .