Merge remote-tracking branch 'origin/main' into feat/tablepro-core-package

Author: datlechin

CHANGELOG.md

@@ -7,6 +7,8 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## [Unreleased]
 
+## [0.27.3] - 2026-04-03
+
 ### Added
 
 - Structure tab context menu with Copy Name, Copy Definition (SQL), Duplicate, and Delete for columns, indexes, and foreign keys
@@ -15,6 +17,10 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 - Data grid: preview and navigate FK references from right-click context menu
 - Data grid: add row from right-click on empty space
 
+### Fixed
+
+- Oracle: crash when opening views caused by OracleNIO state-machine corruption from concurrent queries, LONG column types, and DBMS_METADATA errors
+
 ## [0.27.2] - 2026-04-02
 
 ### Added
@@ -1142,7 +1148,8 @@ TablePro is a native macOS database client built with SwiftUI and AppKit, design
     - Custom SQL query templates
     - Performance optimized for large datasets
 
-[Unreleased]: https://github.com/TableProApp/TablePro/compare/v0.27.2...HEAD
+[Unreleased]: https://github.com/TableProApp/TablePro/compare/v0.27.3...HEAD
+[0.27.3]: https://github.com/TableProApp/TablePro/compare/v0.27.2...v0.27.3
 [0.27.2]: https://github.com/TableProApp/TablePro/compare/v0.27.1...v0.27.2
 [0.27.1]: https://github.com/TableProApp/TablePro/compare/v0.27.0...v0.27.1
 [0.27.0]: https://github.com/TableProApp/TablePro/compare/v0.26.0...v0.27.0

Plugins/OracleDriverPlugin/OracleConnection.swift

@@ -39,12 +39,39 @@ struct OracleQueryResult {
     let isTruncated: Bool
 }
 
+// MARK: - Query Serialization
+
+/// OracleNIO does not support concurrent queries on a single connection.
+/// Sending a second statement while the first stream is active corrupts the
+/// state machine. This actor serializes all executeQuery calls.
+private actor QueryGate {
+    private var busy = false
+    private var waiters: [CheckedContinuation<Void, Never>] = []
+
+    func acquire() async {
+        if !busy {
+            busy = true
+            return
+        }
+        await withCheckedContinuation { waiters.append($0) }
+    }
+
+    func release() {
+        if !waiters.isEmpty {
+            waiters.removeFirst().resume()
+        } else {
+            busy = false
+        }
+    }
+}
+
 // MARK: - Connection Class
 
 final class OracleConnectionWrapper: @unchecked Sendable {
     // MARK: - Properties
 
     private static let connectionCounter = OSAllocatedUnfairLock(initialState: 0)
+    private let queryGate = QueryGate()
 
     private let host: String
     private let port: Int
@@ -143,6 +170,10 @@ final class OracleConnectionWrapper: @unchecked Sendable {
         }
         lock.unlock()
 
+        // OracleNIO does not support concurrent queries on a single connection.
+        // Serialize all queries to prevent state-machine corruption.
+        await queryGate.acquire()
+
         do {
             let statement = OracleStatement(stringLiteral: query)
             let stream = try await connection.execute(statement, logger: nioLogger)
@@ -183,6 +214,7 @@ final class OracleConnectionWrapper: @unchecked Sendable {
                 columnTypeNames = Array(repeating: "unknown", count: columns.count)
             }
 
+            await queryGate.release()
             return OracleQueryResult(
                 columns: columns,
                 columnTypeNames: columnTypeNames,
@@ -192,12 +224,16 @@ final class OracleConnectionWrapper: @unchecked Sendable {
             )
         } catch let sqlError as OracleSQLError {
             let detail = sqlError.serverInfo?.message ?? sqlError.description
+            await queryGate.release()
             throw OracleError(message: detail)
         } catch let error as OracleError {
+            await queryGate.release()
             throw error
         } catch is CancellationError {
+            await queryGate.release()
             throw CancellationError()
         } catch {
+            await queryGate.release()
             throw OracleError(message: "Query execution failed: \(String(describing: error))")
         }
     }

Plugins/OracleDriverPlugin/OraclePlugin.swift

@@ -401,7 +401,6 @@ final class OraclePluginDriver: PluginDatabaseDriver, @unchecked Sendable {
                 c.DATA_PRECISION,
                 c.DATA_SCALE,
                 c.NULLABLE,
-                c.DATA_DEFAULT,
                 CASE WHEN cc.COLUMN_NAME IS NOT NULL THEN 'Y' ELSE 'N' END AS IS_PK
             FROM ALL_TAB_COLUMNS c
             LEFT JOIN (
@@ -424,8 +423,7 @@ final class OraclePluginDriver: PluginDatabaseDriver, @unchecked Sendable {
             let precision = row[safe: 4] ?? nil
             let scale = row[safe: 5] ?? nil
             let isNullable = (row[safe: 6] ?? nil) == "Y"
-            let defaultValue = (row[safe: 7] ?? nil)?.trimmingCharacters(in: .whitespacesAndNewlines)
-            let isPk = (row[safe: 8] ?? nil) == "Y"
+            let isPk = (row[safe: 7] ?? nil) == "Y"
 
             let fullType = buildOracleFullType(dataType: dataType, dataLength: dataLength, precision: precision, scale: scale)
 
@@ -434,7 +432,7 @@ final class OraclePluginDriver: PluginDatabaseDriver, @unchecked Sendable {
                 dataType: fullType,
                 isNullable: isNullable,
                 isPrimaryKey: isPk,
-                defaultValue: defaultValue
+                defaultValue: nil
             )
             columnsByTable[tableName, default: []].append(col)
         }
@@ -509,15 +507,10 @@ final class OraclePluginDriver: PluginDatabaseDriver, @unchecked Sendable {
     func fetchTableDDL(table: String, schema: String?) async throws -> String {
         let escapedTable = table.replacingOccurrences(of: "'", with: "''")
         let escaped = effectiveSchemaEscaped(schema)
-        let sql = "SELECT DBMS_METADATA.GET_DDL('TABLE', '\(escapedTable)', '\(escaped)') FROM DUAL"
-        do {
-            let result = try await execute(query: sql)
-            if let row = result.rows.first, let ddl = row.first ?? nil {
-                return ddl
-            }
-        } catch {
-            Self.logger.debug("DBMS_METADATA failed, building DDL manually: \(error.localizedDescription)")
-        }
+
+        // Do NOT use DBMS_METADATA.GET_DDL — if the object type is wrong
+        // (view, materialized view, etc.), Oracle returns ORA-31603 which
+        // corrupts OracleNIO's connection state machine. Build DDL manually.
 
         let cols = try await fetchColumns(table: table, schema: schema)
         var ddl = "CREATE TABLE \"\(escaped)\".\"\(escapedTable)\" (\n"
@@ -535,9 +528,10 @@ final class OraclePluginDriver: PluginDatabaseDriver, @unchecked Sendable {
     func fetchViewDefinition(view: String, schema: String?) async throws -> String {
         let escapedView = view.replacingOccurrences(of: "'", with: "''")
         let escaped = effectiveSchemaEscaped(schema)
-        // Use DBMS_METADATA.GET_DDL instead of ALL_VIEWS.TEXT to avoid LONG column type
-        // that crashes OracleNIO's decoder
-        let sql = "SELECT DBMS_METADATA.GET_DDL('VIEW', '\(escapedView)', '\(escaped)') FROM DUAL"
+        // ALL_VIEWS.TEXT is LONG (crashes OracleNIO). TEXT_VC is VARCHAR2(4000), safe.
+        // Do NOT use DBMS_METADATA.GET_DDL — wrong object type triggers ORA-31603
+        // which corrupts OracleNIO's connection state machine.
+        let sql = "SELECT TEXT_VC FROM ALL_VIEWS WHERE VIEW_NAME = '\(escapedView)' AND OWNER = '\(escaped)'"
         let result = try await execute(query: sql)
         return result.rows.first?.first?.flatMap { $0 } ?? ""
     }

TablePro.xcodeproj/project.pbxproj

@@ -2093,7 +2093,7 @@
 				CODE_SIGN_IDENTITY = "Apple Development";
 				"CODE_SIGN_IDENTITY[sdk=macosx*]" = "Apple Development";
 				CODE_SIGN_STYLE = Automatic;
-				CURRENT_PROJECT_VERSION = 55;
+				CURRENT_PROJECT_VERSION = 56;
 				DEAD_CODE_STRIPPING = YES;
 				DEVELOPMENT_TEAM = D7HJ5TFYCU;
 				ENABLE_APP_SANDBOX = NO;
@@ -2118,7 +2118,7 @@
 				LD_RUNPATH_SEARCH_PATHS = "@executable_path/Frameworks";
 				"LD_RUNPATH_SEARCH_PATHS[sdk=macosx*]" = "@executable_path/../Frameworks";
 				MACOSX_DEPLOYMENT_TARGET = 14.0;
-				MARKETING_VERSION = 0.27.2;
+				MARKETING_VERSION = 0.27.3;
 				OTHER_LDFLAGS = (
 					"-Wl,-w",
 					"-force_load",
@@ -2165,7 +2165,7 @@
 				"CODE_SIGN_IDENTITY[sdk=macosx*]" = "Apple Development";
 				CODE_SIGN_STYLE = Automatic;
 				COPY_PHASE_STRIP = YES;
-				CURRENT_PROJECT_VERSION = 55;
+				CURRENT_PROJECT_VERSION = 56;
 				DEAD_CODE_STRIPPING = YES;
 				DEPLOYMENT_POSTPROCESSING = YES;
 				DEVELOPMENT_TEAM = D7HJ5TFYCU;
@@ -2191,7 +2191,7 @@
 				LD_RUNPATH_SEARCH_PATHS = "@executable_path/Frameworks";
 				"LD_RUNPATH_SEARCH_PATHS[sdk=macosx*]" = "@executable_path/../Frameworks";
 				MACOSX_DEPLOYMENT_TARGET = 14.0;
-				MARKETING_VERSION = 0.27.2;
+				MARKETING_VERSION = 0.27.3;
 				OTHER_LDFLAGS = (
 					"-Wl,-w",
 					"-force_load",

TablePro/Core/SchemaTracking/SchemaStatementGenerator.swift

@@ -237,5 +237,4 @@ struct SchemaStatementGenerator {
             isDestructive: true
         )
     }
-
 }

docs/changelog.mdx

@@ -4,6 +4,18 @@ description: "Product updates and announcements for TablePro"
 rss: true
 ---
 
+<Update label="April 3, 2026" description="v0.27.3">
+  ### New Features
+
+  - **Foreign Key Preview**: Cmd+Enter or right-click on FK cells to preview referenced rows
+  - **Structure Tab Context Menu**: Copy Name, Copy Definition, Duplicate, and Delete for columns, indexes, and foreign keys
+  - **Column Header Context Menu**: Sort and show/hide columns from header right-click
+
+  ### Bug Fixes
+
+  - Fixed Oracle crash when opening views
+</Update>
+
 <Update label="April 2, 2026" description="v0.27.2">
   ### New Features