update (#28)

Author: swuecho

templates/query.tmpl

@@ -54,7 +54,9 @@ let {{.MethodName}} (db: NpgsqlConnection) {{if .Arg.Pair}} ({{.Arg.Pair}}) {{-
   db
   |> Sql.existingConnection
   |> Sql.query {{.ConstantName}}
+  {{ if .Arg.NpgsqlParams -}}
   |> Sql.parameters  [ {{ .Arg.NpgsqlParams }} ]
+  {{ end -}}
   |> Sql.executeRow{{if $.Options.EmitAsyncCode}}Async{{end}} reader
 {{end}}
 
@@ -70,6 +72,9 @@ let {{.MethodName}} (db: NpgsqlConnection) {{if .Arg.Pair}} ({{.Arg.Pair}}) {{-
   db 
   |> Sql.existingConnection
   |> Sql.query {{.ConstantName}}
+  {{ if .Arg.NpgsqlParams -}}
+  |> Sql.parameters  [ {{ .Arg.NpgsqlParams }} ]
+  {{ end -}}
   |> Sql.execute{{if $.Options.EmitAsyncCode}}Async{{end}} reader
 {{end}}
 
@@ -80,7 +85,9 @@ let {{.MethodName}} (db: NpgsqlConnection) {{if .Arg.Pair}} ({{.Arg.Pair}}) {{-
   db 
   |> Sql.existingConnection
   |> Sql.query {{.ConstantName}}
+  {{ if .Arg.NpgsqlParams -}}
   |> Sql.parameters  [ {{ .Arg.NpgsqlParams }} ]
+  {{ end -}}
   |> Sql.executeNonQuery{{if $.Options.EmitAsyncCode}}Async{{end}}
 {{end}}
 
@@ -91,7 +98,9 @@ let {{.MethodName}} (db: NpgsqlConnection) {{if .Arg.Pair}} ({{.Arg.Pair}}) {{-
   db 
   |> Sql.existingConnection
   |> Sql.query {{.ConstantName}}
+  {{ if .Arg.NpgsqlParams -}}
   |> Sql.parameters  [ {{ .Arg.NpgsqlParams }} ]
+  {{ end -}}
   |> Sql.executeNonQuery{{if $.Options.EmitAsyncCode }}Async{{end}}
 {{end}}
 
@@ -102,7 +111,10 @@ let {{.MethodName}} (db: NpgsqlConnection) {{if .Arg.Pair}} ({{.Arg.Pair}}) {{-
   db 
   |> Sql.existingConnection
   |> Sql.query {{.ConstantName}}
+  {{ if .Arg.NpgsqlParams -}}
   |> Sql.parameters  [ {{ .Arg.NpgsqlParams }} ]
+
+  {{ end -}}
   |> Sql.execute{{if $.Options.EmitAsyncCode}}Async{{end}}
 {{ end }}
 

testdata/gen/auth_user.sql.fs

@@ -266,7 +266,6 @@ let GetTotalActiveUserCount (db: NpgsqlConnection)   =
   db
   |> Sql.existingConnection
   |> Sql.query getTotalActiveUserCount
-  |> Sql.parameters  [  ]
   |> Sql.executeRow reader
 
 
@@ -381,6 +380,7 @@ let GetUserStats (db: NpgsqlConnection)  (arg: GetUserStatsParams) =
   db 
   |> Sql.existingConnection
   |> Sql.query getUserStats
+  |> Sql.parameters  [ "@limit", Sql.int arg.Limit; "@offset", Sql.int arg.Offset; "@default_rate_limit", Sql.int arg.DefaultRateLimit ]
   |> Sql.execute reader
 
 
@@ -422,6 +422,7 @@ let ListAuthUsers (db: NpgsqlConnection)  (arg: ListAuthUsersParams) =
   db 
   |> Sql.existingConnection
   |> Sql.query listAuthUsers
+  |> Sql.parameters  [ "@limit", Sql.int arg.Limit; "@offset", Sql.int arg.Offset ]
   |> Sql.execute reader
 
 

testdata/gen/chat_message.sql.fs

@@ -397,6 +397,7 @@ let GetChatMessagesBySessionUUID (db: NpgsqlConnection)  (arg: GetChatMessagesBy
   db 
   |> Sql.existingConnection
   |> Sql.query getChatMessagesBySessionUUID
+  |> Sql.parameters  [ "@uuid", Sql.string arg.Uuid; "@offset", Sql.int arg.Offset; "@limit", Sql.int arg.Limit ]
   |> Sql.execute reader
 
 
@@ -583,6 +584,7 @@ let GetLastNChatMessages (db: NpgsqlConnection)  (arg: GetLastNChatMessagesParam
   db 
   |> Sql.existingConnection
   |> Sql.query getLastNChatMessages
+  |> Sql.parameters  [ "@uuid", Sql.string arg.Uuid; "@limit", Sql.int arg.Limit; "@chat_session_uuid", Sql.string arg.ChatSessionUuid ]
   |> Sql.execute reader
 
 
@@ -641,6 +643,7 @@ let GetLatestMessagesBySessionUUID (db: NpgsqlConnection)  (arg: GetLatestMessag
   db 
   |> Sql.existingConnection
   |> Sql.query getLatestMessagesBySessionUUID
+  |> Sql.parameters  [ "@chat_session_uuid", Sql.string arg.ChatSessionUuid; "@limit", Sql.int arg.Limit ]
   |> Sql.execute reader
 
 

testdata/gen/chat_model.sql.fs

@@ -236,7 +236,6 @@ let GetDefaultChatModel (db: NpgsqlConnection)   =
   db
   |> Sql.existingConnection
   |> Sql.query getDefaultChatModel
-  |> Sql.parameters  [  ]
   |> Sql.executeRow reader
 
 

testdata/gen/chat_prompt.sql.fs

@@ -306,6 +306,7 @@ let GetChatPromptsBySessionUUID (db: NpgsqlConnection)  (chatSessionUuid: string
   db 
   |> Sql.existingConnection
   |> Sql.query getChatPromptsBySessionUUID
+  |> Sql.parameters  [ "@chat_session_uuid", Sql.string chatSessionUuid ]
   |> Sql.execute reader
 
 
@@ -345,6 +346,7 @@ let GetChatPromptsByUserID (db: NpgsqlConnection)  (userId: int32) =
   db 
   |> Sql.existingConnection
   |> Sql.query getChatPromptsByUserID
+  |> Sql.parameters  [ "@user_id", Sql.int userId ]
   |> Sql.execute reader
 
 
@@ -384,6 +386,7 @@ let GetChatPromptsBysession_uuid (db: NpgsqlConnection)  (chatSessionUuid: strin
   db 
   |> Sql.existingConnection
   |> Sql.query getChatPromptsBysession_uuid
+  |> Sql.parameters  [ "@chat_session_uuid", Sql.string chatSessionUuid ]
   |> Sql.execute reader
 
 

testdata/gen/chat_session.sql.fs

@@ -472,6 +472,7 @@ let GetChatSessionsByUserID (db: NpgsqlConnection)  (userId: int32) =
   db 
   |> Sql.existingConnection
   |> Sql.query getChatSessionsByUserID
+  |> Sql.parameters  [ "@user_id", Sql.int userId ]
   |> Sql.execute reader
 
 

testdata/gen/chat_snapshot.sql.fs

@@ -120,6 +120,7 @@ let ChatSnapshotMetaByUserID (db: NpgsqlConnection)  (userId: int32) =
   db 
   |> Sql.existingConnection
   |> Sql.query chatSnapshotMetaByUserID
+  |> Sql.parameters  [ "@user_id", Sql.int userId ]
   |> Sql.execute reader
 
 
@@ -159,6 +160,7 @@ let ChatSnapshotSearch (db: NpgsqlConnection)  (arg: ChatSnapshotSearchParams) =
   db 
   |> Sql.existingConnection
   |> Sql.query chatSnapshotSearch
+  |> Sql.parameters  [ "@user_id", Sql.int arg.UserId; "@search", Sql.string arg.Search ]
   |> Sql.execute reader
 
 

testdata/gen/chat_user_chat_model_privilege.sql.fs

@@ -208,6 +208,7 @@ let ListUserChatModelPrivilegesByUserID (db: NpgsqlConnection)  (userId: int32)
   db 
   |> Sql.existingConnection
   |> Sql.query listUserChatModelPrivilegesByUserID
+  |> Sql.parameters  [ "@user_id", Sql.int userId ]
   |> Sql.execute reader