This is an automated email from the ASF dual-hosted git repository.
virajjasani pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/phoenix-adapters.git
The following commit(s) were added to refs/heads/main by this push:
new d92b7b3 Log all DDL statements
d92b7b3 is described below
commit d92b7b38f52edab648c7fc2d8146afe05c3fd154
Author: Viraj Jasani <[email protected]>
AuthorDate: Mon Mar 30 09:51:31 2026 -0700
Log all DDL statements
---
.../java/org/apache/phoenix/ddb/service/CreateTableService.java | 6 +++---
.../java/org/apache/phoenix/ddb/service/DeleteTableService.java | 2 +-
.../src/main/java/org/apache/phoenix/ddb/service/TTLService.java | 2 +-
.../java/org/apache/phoenix/ddb/service/UpdateTableService.java | 6 +++---
4 files changed, 8 insertions(+), 8 deletions(-)
diff --git
a/phoenix-ddb-rest/src/main/java/org/apache/phoenix/ddb/service/CreateTableService.java
b/phoenix-ddb-rest/src/main/java/org/apache/phoenix/ddb/service/CreateTableService.java
index 290f558..3b5d0ea 100644
---
a/phoenix-ddb-rest/src/main/java/org/apache/phoenix/ddb/service/CreateTableService.java
+++
b/phoenix-ddb-rest/src/main/java/org/apache/phoenix/ddb/service/CreateTableService.java
@@ -340,14 +340,14 @@ public class CreateTableService {
try {
PhoenixConnection phoenixConnection =
connection.unwrap(PhoenixConnection.class);
tableExists = checkTableExistence(phoenixConnection, tableName);
- LOGGER.debug("Create Table Query: {}", createTableDDL);
+ LOGGER.info("Create Table DDL: {}", createTableDDL);
connection.createStatement().execute(createTableDDL);
for (String createIndexDDL : createIndexDDLs) {
- LOGGER.debug("Create Index Query: {}", createIndexDDL);
+ LOGGER.info("Create Index DDL: {}", createIndexDDL);
connection.createStatement().execute(createIndexDDL);
}
for (String ddl : createCdcDDLs) {
- LOGGER.debug("CDC DDL: {}", ddl);
+ LOGGER.info("Create CDC DDL: {}", ddl);
connection.createStatement().execute(ddl);
}
} catch (SQLException e) {
diff --git
a/phoenix-ddb-rest/src/main/java/org/apache/phoenix/ddb/service/DeleteTableService.java
b/phoenix-ddb-rest/src/main/java/org/apache/phoenix/ddb/service/DeleteTableService.java
index 411bfad..cf53dab 100644
---
a/phoenix-ddb-rest/src/main/java/org/apache/phoenix/ddb/service/DeleteTableService.java
+++
b/phoenix-ddb-rest/src/main/java/org/apache/phoenix/ddb/service/DeleteTableService.java
@@ -41,7 +41,7 @@ public class DeleteTableService {
TableDescriptorUtils.getTableDescription(tableName,
connectionUrl,
"TableDescription");
String deleteTableDDL = "DROP TABLE " +
PhoenixUtils.getFullTableName(tableName, true) + " CASCADE";
- LOGGER.debug("Delete Table Query: {}", deleteTableDDL);
+ LOGGER.info("Delete Table DDL: {}", deleteTableDDL);
try (Connection connection =
ConnectionUtil.getConnection(connectionUrl)) {
connection.createStatement().execute(deleteTableDDL);
diff --git
a/phoenix-ddb-rest/src/main/java/org/apache/phoenix/ddb/service/TTLService.java
b/phoenix-ddb-rest/src/main/java/org/apache/phoenix/ddb/service/TTLService.java
index 6dd36c8..e39a4ec 100644
---
a/phoenix-ddb-rest/src/main/java/org/apache/phoenix/ddb/service/TTLService.java
+++
b/phoenix-ddb-rest/src/main/java/org/apache/phoenix/ddb/service/TTLService.java
@@ -36,7 +36,7 @@ public class TTLService {
} else {
alterStmt = String.format(ALTER_TTL_STMT, fullTableName,
HConstants.FOREVER);
}
- LOGGER.debug("SQL for UpdateTimeToLive: {}", alterStmt);
+ LOGGER.info("DDL for UpdateTimeToLive: {}", alterStmt);
try (Connection connection =
ConnectionUtil.getConnection(connectionUrl)) {
connection.createStatement().execute(alterStmt);
} catch (SQLException e) {
diff --git
a/phoenix-ddb-rest/src/main/java/org/apache/phoenix/ddb/service/UpdateTableService.java
b/phoenix-ddb-rest/src/main/java/org/apache/phoenix/ddb/service/UpdateTableService.java
index f6fd80b..a334bb0 100644
---
a/phoenix-ddb-rest/src/main/java/org/apache/phoenix/ddb/service/UpdateTableService.java
+++
b/phoenix-ddb-rest/src/main/java/org/apache/phoenix/ddb/service/UpdateTableService.java
@@ -64,7 +64,7 @@ public class UpdateTableService {
final String finalIndexName =
PhoenixUtils.getInternalIndexName(tableName, indexName);
String ddl = String.format(DROP_INDEX_SQL, finalIndexName,
PhoenixUtils.getFullTableName(tableName, true));
- LOGGER.debug("DDL for Disable Index: {}", ddl);
+ LOGGER.info("DDL for Disable Index: {}", ddl);
indexDDLs.add(ddl);
} else if (indexUpdate.containsKey(ApiMetadata.CREATE)) {
Map<String, Object> createIndexUpdate
@@ -76,7 +76,7 @@ public class UpdateTableService {
List<Map<String, Object>> keySchema
= (List<Map<String, Object>>)
createIndexUpdate.get(ApiMetadata.KEY_SCHEMA);
CreateTableService.addIndexDDL(tableName, keySchema,
attrDefs, indexDDLs, indexName, true);
- LOGGER.debug("DDL for Create Index: {}", indexDDLs);
+ LOGGER.info("DDL for Create Index: {}", indexDDLs);
indexDDLs.addAll(ddl);
} else {
throw new ValidationException("Only Create and Delete
index is supported in UpdateTable API.");
@@ -122,7 +122,7 @@ public class UpdateTableService {
cdcDDLs.add(String.format(ALTER_MERGE_SQL,
PhoenixUtils.getFullTableName(table.getTableName().getString(), true)));
- LOGGER.debug("DDLs for Update CDC: {} ", cdcDDLs);
+ LOGGER.info("DDLs for Update CDC: {} ", cdcDDLs);
return cdcDDLs;
}
}
