Allow setting any schema (#6)

* Allow setting any schema

Co-authored-by: Till Schröder <[email protected]>

* Enable setting schema also for store with pooling

Co-authored-by: Rasmus Larsson <[email protected]>

Author: roetlich

src/Postgres.fs

@@ -7,7 +7,8 @@ type PostgresConfig =
       port: string
       username: string
       password: string
-      database: string }
+      database: string
+      schema: string option }
 
 type PoolingConfig =
     { minPoolSize: int option
@@ -50,12 +51,28 @@ module Postgres =
     let private storeSettingsWithPooling (config: PostgresConfig) (pooling: PoolingConfig): string =
         sprintf "%s;%s" (storeSettings config) (poolingSettings pooling)
 
+    let private setSettingsSchema (config: PostgresConfig)
+                                  (settings: SqlStreamStore.PostgresStreamStoreSettings)
+                                  : SqlStreamStore.PostgresStreamStoreSettings =
+        match config.schema with
+        | None -> ()
+        | Some (schema) -> settings.Schema <- schema
+
+        settings
+
     let createStore (config: PostgresConfig): SqlStreamStore.PostgresStreamStore =
-        new SqlStreamStore.PostgresStreamStore(SqlStreamStore.PostgresStreamStoreSettings(storeSettings config))
+        let settings =
+            SqlStreamStore.PostgresStreamStoreSettings(storeSettings config)
+            |> setSettingsSchema config
+
+        new SqlStreamStore.PostgresStreamStore(settings)
 
     let createStoreWithPoolingConfig (config: PostgresConfig) (pooling: PoolingConfig): SqlStreamStore.PostgresStreamStore =
-        new SqlStreamStore.PostgresStreamStore(SqlStreamStore.PostgresStreamStoreSettings
-                                                   (storeSettingsWithPooling config pooling))
+        let settings =
+            SqlStreamStore.PostgresStreamStoreSettings(storeSettingsWithPooling config pooling)
+            |> setSettingsSchema config
+
+        new SqlStreamStore.PostgresStreamStore(settings)
 
     let createStoreWithConfigString (config: string): SqlStreamStore.PostgresStreamStore =
         new SqlStreamStore.PostgresStreamStore(SqlStreamStore.PostgresStreamStoreSettings(config))