Remove transaction argument from DDLManager::createColumn

The transaction can be retrieved from the Statement object.
polypheny · Dec 23, 2024 · 5df5c4a · 5df5c4a
1 parent 83cca1e
commit 5df5c4a
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 5 deletions.
diff --git a/core/src/main/java/org/polypheny/db/ddl/DdlManager.java b/core/src/main/java/org/polypheny/db/ddl/DdlManager.java
@@ -159,7 +159,6 @@ public static DdlManager getInstance() {
     /**
      * Add a column to an existing table
      *
-     * @param transaction current transaction
      * @param columnName the name of the new column
      * @param table the table
      * @param beforeColumnName the column before which the new column should be positioned; can be null
@@ -169,7 +168,7 @@ public static DdlManager getInstance() {
      * @param defaultValue a default value for the column; can be null
      * @param statement the query statement
      */
-    public abstract void createColumn( Transaction transaction, String columnName, LogicalTable table, String beforeColumnName, String afterColumnName, ColumnTypeInformation type, boolean nullable, PolyValue defaultValue, Statement statement );
+    public abstract void createColumn( String columnName, LogicalTable table, String beforeColumnName, String afterColumnName, ColumnTypeInformation type, boolean nullable, PolyValue defaultValue, Statement statement );
 
     /**
      * Add a foreign key to a table

diff --git a/dbms/src/main/java/org/polypheny/db/ddl/DdlManagerImpl.java b/dbms/src/main/java/org/polypheny/db/ddl/DdlManagerImpl.java
@@ -456,7 +456,7 @@ private void updateColumnPosition( LogicalTable table, LogicalColumn column, int
 
 
     @Override
-    public void createColumn( Transaction transaction, String columnName, LogicalTable table, String beforeColumnName, String afterColumnName, ColumnTypeInformation type, boolean nullable, PolyValue defaultValue, Statement statement ) {
+    public void createColumn( String columnName, LogicalTable table, String beforeColumnName, String afterColumnName, ColumnTypeInformation type, boolean nullable, PolyValue defaultValue, Statement statement ) {
         columnName = adjustNameIfNeeded( columnName, table.namespaceId );
         // Check if the column either allows null values or has a default value defined.
         if ( defaultValue == null && !nullable ) {
@@ -495,7 +495,7 @@ public void createColumn( Transaction transaction, String columnName, LogicalTab
         List<DataStore<?>> stores = RoutingManager.getInstance().getCreatePlacementStrategy().getDataStoresForNewRelField( addedColumn );
 
         // Add column on underlying data stores and insert default value
-        transaction.attachCommitAction( () -> {
+        statement.getTransaction().attachCommitAction( () -> {
             for ( DataStore<?> store : stores ) {
                 AllocationPlacement placement = catalog.getSnapshot().alloc().getPlacement( store.getAdapterId(), table.id ).orElseThrow();
 

diff --git a/...ge/src/main/java/org/polypheny/db/sql/language/ddl/altertable/SqlAlterTableAddColumn.java b/...ge/src/main/java/org/polypheny/db/sql/language/ddl/altertable/SqlAlterTableAddColumn.java
@@ -141,7 +141,6 @@ public void execute( Context context, Statement statement, ParsedQueryContext pa
         }
 
         DdlManager.getInstance().createColumn(
-                statement.getTransaction(),
                 column.getSimple(),
                 logicalTable,
                 beforeColumnName == null ? null : beforeColumnName.getSimple(),