@@ -61,15 +61,14 @@ public void generateDatabase(HiveGlobalState globalState) throws Exception {
6161 String tableName = globalState .getSchema ().getFreeTableName ();
6262 SQLQueryAdapter qt = HiveTableGenerator .generate (globalState , tableName );
6363 success = globalState .executeStatement (qt );
64- } while (!success );
64+ } while (!success );
6565 }
6666 if (globalState .getSchema ().getDatabaseTables ().isEmpty ()) {
6767 throw new IgnoreMeException (); // TODO
6868 }
6969
70- StatementExecutor <HiveGlobalState , Action > se = new StatementExecutor <HiveGlobalState , Action >(
71- globalState , Action .values (),
72- HiveProvider ::mapActions , (q ) -> {
70+ StatementExecutor <HiveGlobalState , Action > se = new StatementExecutor <HiveGlobalState , Action >(globalState ,
71+ Action .values (), HiveProvider ::mapActions , (q ) -> {
7372 if (globalState .getSchema ().getDatabaseTables ().isEmpty ()) {
7473 throw new IgnoreMeException ();
7574 }
@@ -107,9 +106,8 @@ public SQLConnection createDatabase(HiveGlobalState globalState) throws SQLExcep
107106 s .execute ("USE " + databaseName );
108107 }
109108 con .close ();
110- con = DriverManager .getConnection (
111- String .format ("jdbc:hive2://%s:%d/%s" , host , port , databaseName ,
112- username , password ));
109+ con = DriverManager
110+ .getConnection (String .format ("jdbc:hive2://%s:%d/%s" , host , port , databaseName , username , password ));
113111
114112 return new SQLConnection (con );
115113 }
0 commit comments