99import com .scalar .db .storage .cassandra .CassandraAdmin ;
1010import com .scalar .db .storage .cassandra .CassandraConfig ;
1111import com .scalar .db .storage .cassandra .ClusterManager ;
12- import com .scalar .db .storage .jdbc .JdbcAdmin ;
1312import com .scalar .db .storage .jdbc .JdbcConfig ;
1413import com .scalar .db .storage .jdbc .JdbcTestUtils ;
1514import com .scalar .db .storage .jdbc .JdbcUtils ;
15+ import com .scalar .db .storage .jdbc .NamespaceMetadataService ;
1616import com .scalar .db .storage .jdbc .RdbEngineFactory ;
1717import com .scalar .db .storage .jdbc .RdbEngineStrategy ;
18+ import com .scalar .db .storage .jdbc .TableMetadataService ;
1819import com .scalar .db .util .AdminTestUtils ;
1920import edu .umd .cs .findbugs .annotations .SuppressFBWarnings ;
2021import java .sql .Connection ;
@@ -61,7 +62,8 @@ public void dropNamespacesTable() throws SQLException {
6162 // for JDBC
6263 execute (
6364 "DROP TABLE "
64- + rdbEngine .encloseFullTableName (jdbcMetadataSchema , JdbcAdmin .NAMESPACES_TABLE ));
65+ + rdbEngine .encloseFullTableName (
66+ jdbcMetadataSchema , NamespaceMetadataService .TABLE_NAME ));
6567 }
6668
6769 @ Override
@@ -71,7 +73,7 @@ public void dropMetadataTable() throws SQLException {
7173 // for JDBC
7274 execute (
7375 "DROP TABLE "
74- + rdbEngine .encloseFullTableName (jdbcMetadataSchema , JdbcAdmin . METADATA_TABLE ));
76+ + rdbEngine .encloseFullTableName (jdbcMetadataSchema , TableMetadataService . TABLE_NAME ));
7577 }
7678
7779 @ Override
@@ -86,7 +88,7 @@ public void truncateNamespacesTable() throws SQLException {
8688
8789 // for JDBC
8890 String truncateTableStatement =
89- rdbEngine .truncateTableSql (jdbcMetadataSchema , JdbcAdmin . NAMESPACES_TABLE );
91+ rdbEngine .truncateTableSql (jdbcMetadataSchema , NamespaceMetadataService . TABLE_NAME );
9092 execute (truncateTableStatement );
9193 }
9294
@@ -97,7 +99,7 @@ public void truncateMetadataTable() throws Exception {
9799 // for JDBC
98100 String truncateTableStatement =
99101 "TRUNCATE TABLE "
100- + rdbEngine .encloseFullTableName (jdbcMetadataSchema , JdbcAdmin . METADATA_TABLE );
102+ + rdbEngine .encloseFullTableName (jdbcMetadataSchema , TableMetadataService . TABLE_NAME );
101103 execute (truncateTableStatement );
102104 }
103105
@@ -109,7 +111,7 @@ public void corruptMetadata(String namespace, String table) throws Exception {
109111 // for JDBC
110112 String insertCorruptedMetadataStatement =
111113 "INSERT INTO "
112- + rdbEngine .encloseFullTableName (jdbcMetadataSchema , JdbcAdmin . METADATA_TABLE )
114+ + rdbEngine .encloseFullTableName (jdbcMetadataSchema , TableMetadataService . TABLE_NAME )
113115 + " VALUES ('"
114116 + getFullTableName (namespace , table )
115117 + "','corrupted','corrupted','corrupted','corrupted','0','0')" ;
@@ -123,9 +125,9 @@ public void deleteMetadata(String namespace, String table) throws Exception {
123125 // for JDBC
124126 String deleteMetadataStatement =
125127 "DELETE FROM "
126- + rdbEngine .encloseFullTableName (jdbcMetadataSchema , JdbcAdmin . METADATA_TABLE )
128+ + rdbEngine .encloseFullTableName (jdbcMetadataSchema , TableMetadataService . TABLE_NAME )
127129 + " WHERE "
128- + rdbEngine .enclose (JdbcAdmin . METADATA_COL_FULL_TABLE_NAME )
130+ + rdbEngine .enclose (TableMetadataService . COL_FULL_TABLE_NAME )
129131 + " = ?" ;
130132 try (Connection connection = dataSource .getConnection ();
131133 PreparedStatement preparedStatement =
0 commit comments