Added advance queuing #25

docker-compose.yml

@@ -1,14 +1,10 @@
-version: "3"
 services:
   dev-db:
     container_name: dev-db
-    image: gvenzl/oracle-free:23-slim-faststart
+    image: container-registry-mumbai.oracle.com/database/free
     volumes:
-      - ./db:/container-entrypoint-startdb.d
+      - ./init-scripts:/opt/oracle/scripts/startup
     environment:
-      ORACLE_DATABASE: devdb
-      ORACLE_PASSWORD: password
-      APP_USER: username
-      APP_USER_PASSWORD: password
+      ORACLE_PWD: password
     ports:
       - 1521:1521

init-scripts/init.sql

@@ -0,0 +1,4 @@
+alter session set "_oracle_script"=true;
+CREATE USER username IDENTIFIED BY password;
+GRANT ALL PRIVILEGES TO username;
+GRANT EXECUTE ON DBMS_AQADM TO username;

oracle-simple.cabal

@@ -39,6 +39,7 @@ library
       Database.Oracle.Simple.ToField
       Database.Oracle.Simple.ToRow
       Database.Oracle.Simple.Transaction
+      Database.Oracle.Simple.Queue
   hs-source-dirs:
       src
   c-sources:
@@ -92,6 +93,7 @@ executable tests
     , hspec-hedgehog
     , oracle-simple
     , time
+    , bytestring
 
 source-repository head
   type: git

src/Database/Oracle/Simple.hs

@@ -10,3 +10,4 @@ import Database.Oracle.Simple.Query as Export
 import Database.Oracle.Simple.ToField as Export
 import Database.Oracle.Simple.ToRow as Export
 import Database.Oracle.Simple.Transaction as Export
+import Database.Oracle.Simple.Queue as Export

src/Database/Oracle/Simple/Internal.hs

@@ -44,6 +44,8 @@ module Database.Oracle.Simple.Internal
     OracleError (..),
     ErrorInfo (..),
     VersionInfo (..),
+    DPIJson (..),
+    genJSON,
     renderErrorInfo,
     ping,
     fetch,
@@ -119,6 +121,10 @@ newtype DPIShardingKeyColumn = DPIShardingKeyColumn (Ptr DPIShardingKeyColumn)
   deriving (Show, Eq)
   deriving newtype (Storable)
 
+newtype DPIJson = DPIJson (Ptr DPIJson)
+  deriving (Show, Eq)
+  deriving newtype (Storable)
+
 data AdditionalConnectionParams = AdditionalConnectionParams
   { minSessions :: Natural
   , maxSessions :: Natural
@@ -207,7 +213,7 @@ foreign import ccall unsafe "dpiConn_create"
     Ptr DPICommonCreateParams ->
     -- | const dpiConnCreateParams *createParams
     Ptr ConnectionCreateParams ->
-    -- | dpi * conn
+    -- | dpiConn ** conn
     Ptr DPIConn ->
     IO CInt
 
@@ -1752,3 +1758,18 @@ Structurally equivalent to 'Data.Functor.Identity.Identity'.
 newtype Only a = Only {fromOnly :: a}
   deriving stock (Eq, Ord, Read, Show, Generic)
   deriving newtype (Enum)
+
+genJSON :: Connection -> IO DPIJson
+genJSON (Connection fptr) = do
+  withForeignPtr fptr $ \conn -> do
+    alloca $ \jsonPtr -> do
+      throwOracleError =<< dpiConn_newJson conn jsonPtr
+      peek jsonPtr
+
+foreign import ccall unsafe "dpiConn_newJson"
+  dpiConn_newJson ::
+    -- | dpiConn *
+    Ptr DPIConn ->
+    -- | dpiJSON **
+    Ptr DPIJson ->
+    IO CInt