diff --git a/src/PrayerTracker.MigrateV9/PrayerTracker.MigrateV9.fsproj b/src/PrayerTracker.MigrateV9/PrayerTracker.MigrateV9.fsproj index 760088f..01efbd8 100644 --- a/src/PrayerTracker.MigrateV9/PrayerTracker.MigrateV9.fsproj +++ b/src/PrayerTracker.MigrateV9/PrayerTracker.MigrateV9.fsproj @@ -15,6 +15,7 @@ + diff --git a/src/PrayerTracker.MigrateV9/Program.fs b/src/PrayerTracker.MigrateV9/Program.fs index c2d2bc8..d4d3761 100644 --- a/src/PrayerTracker.MigrateV9/Program.fs +++ b/src/PrayerTracker.MigrateV9/Program.fs @@ -76,11 +76,13 @@ open Npgsql.FSharp open PrayerTracker.Data task { - + Configuration.useConnectionString (Environment.GetEnvironmentVariable "PT_SQLITE_CONN") do! Connection.setUp () - - use source = NpgsqlDataSourceBuilder(Environment.GetEnvironmentVariable "PT_PG_CONN").Build() + + let builder = NpgsqlDataSourceBuilder(Environment.GetEnvironmentVariable "PT_PG_CONN") + let _ = builder.UseNodaTime() + use source = builder.Build() let! churches = Sql.fromDataSource source @@ -122,8 +124,8 @@ task { for user in users do let! groups = Sql.fromDataSource source - |> Sql.query "SELECT small_group_id FROM pt.user_small_group WHERE user_id = :user_id" - |> Sql.parameters [ ":user_id", Sql.uuid user.Id.Value ] + |> Sql.query "SELECT small_group_id FROM pt.user_small_group WHERE user_id = @user_id" + |> Sql.parameters [ "@user_id", Sql.uuid user.Id.Value ] |> Sql.executeAsync (fun row -> (row.uuid >> SmallGroupId) "small_group_id") do! Users.save { user with SmallGroups = groups } printfn "Migrated %d users" users.Length diff --git a/src/PrayerTracker/data/.gitkeep b/src/PrayerTracker/data/.gitkeep new file mode 100644 index 0000000..e69de29