Merge pull request #203 from maxtidev/develop

Make creating indices idempotent
moigagoo · Jul 5, 2024 · ccac566 · ccac566
2 parents 18e09e9 + 9e35af8
commit ccac566
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/src/norm/postgres.nim b/src/norm/postgres.nim
@@ -159,14 +159,14 @@ proc createTables*[T: Model](dbConn; obj: T) =
   dbConn.exec(sql qry)
 
   for index, cols in indexes.pairs:
-    let qry = "CREATE INDEX $# ON $#($#);" % [index, T.table, cols.join(", ")]
+    let qry = "CREATE INDEX IF NOT EXISTS $# ON $#($#);" % [index, T.table, cols.join(", ")]
 
     log(qry)
 
     dbConn.exec(sql qry)
 
   for index, cols in uniqueIndexes.pairs:
-    let qry = "CREATE UNIQUE INDEX $# ON $#($#);" % [index, T.table, cols.join(", ")]
+    let qry = "CREATE UNIQUE INDEX IF NOT EXISTS $# ON $#($#);" % [index, T.table, cols.join(", ")]
 
     log(qry)
 

diff --git a/src/norm/sqlite.nim b/src/norm/sqlite.nim
@@ -146,14 +146,14 @@ proc createTables*[T: Model](dbConn; obj: T) =
   dbConn.exec(sql qry)
 
   for index, cols in indexes.pairs:
-    let qry = "CREATE INDEX $# ON $#($#);" % [index, T.table, cols.join(", ")]
+    let qry = "CREATE INDEX IF NOT EXISTS $# ON $#($#);" % [index, T.table, cols.join(", ")]
 
     log(qry)
 
     dbConn.exec(sql qry)
 
   for index, cols in uniqueIndexes.pairs:
-    let qry = "CREATE UNIQUE INDEX $# ON $#($#);" % [index, T.table, cols.join(", ")]
+    let qry = "CREATE UNIQUE INDEX IF NOT EXISTS $# ON $#($#);" % [index, T.table, cols.join(", ")]
 
     log(qry)