Stored procedure proposal.

Author: jeffgabhart

src/ServiceStack.OrmLite.PostgreSQL.Tests/OrmLiteExecuteProcedureTests.cs

@@ -57,13 +57,12 @@ public void Can_execute_stored_procedure_with_array_arguments()
                 db.ExecuteSql(Create);
                 db.GetLastSql().Print();
 
-                var command = db.CreateCommand();
-                var dialect = command.GetDialectProvider();
-                ((PostgreSQLDialectProvider)dialect).ExecuteFunction(command, new ServiceStackFunction
+                db.ExecuteProcedure(new ServiceStackFunction
                 {
                     StringValues = new[] { "ServiceStack", "Thoughtfully Architected" },
                     IntegerValues = new[] { 1, 2, 3 }
                 });
+
                 db.ExecuteSql(Drop);
             }
         }

src/ServiceStack.OrmLite.PostgreSQL/PostgreSQLDialectProvider.cs

@@ -371,24 +371,24 @@ protected override object GetValue<T>(FieldDefinition fieldDef, object obj)
             return base.GetValue<T>(fieldDef, obj);
         }
 
-        public void ExecuteFunction<T>(IDbCommand dbCommand, T obj)
+        public override void PrepareStoredProcedureStatement<T>(IDbCommand cmd, T obj)
         {
             var tableType = obj.GetType();
             var modelDef = GetModel(tableType);
 
-            dbCommand.CommandText = GetQuotedTableName(modelDef);
-            dbCommand.CommandType = CommandType.StoredProcedure;
+            cmd.CommandText = GetQuotedTableName(modelDef);
+            cmd.CommandType = CommandType.StoredProcedure;
 
             foreach (var fieldDef in modelDef.FieldDefinitions)
             {
-                var p = dbCommand.CreateParameter();
+                var p = cmd.CreateParameter();
                 SetParameter(fieldDef, p);
-                dbCommand.Parameters.Add(p);
+                cmd.Parameters.Add(p);
             }
 
-            SetParameterValues<T>(dbCommand, obj);
+            SetParameterValues<T>(cmd, obj);
 
-            dbCommand.ExecuteNonQuery();
+            cmd.ExecuteNonQuery();
         }
     }
 }

src/ServiceStack.OrmLite/IOrmLiteDialectProvider.cs

@@ -86,6 +86,8 @@ string GetColumnDefinition(
 
         bool PrepareParameterizedDeleteStatement<T>(IDbCommand cmd, ICollection<string> deleteFields = null);
 
+        void PrepareStoredProcedureStatement<T>(IDbCommand cmd, T obj);
+
         void SetParameterValues<T>(IDbCommand dbCmd, object obj);
 
         Dictionary<string, FieldDefinition> GetFieldDefinitionMap(ModelDefinition modelDef);

src/ServiceStack.OrmLite/OrmLiteDialectProviderBase.cs

@@ -688,6 +688,12 @@ public virtual bool PrepareParameterizedDeleteStatement<T>(IDbCommand cmd, IColl
             return hadRowVesion;
         }
 
+        public virtual void PrepareStoredProcedureStatement<T>(IDbCommand cmd, T obj)
+        {
+            cmd.CommandText = ToExecuteProcedureStatement(obj);
+            cmd.CommandType = CommandType.StoredProcedure;
+        }
+
         protected void AddParameter(IDbCommand cmd, FieldDefinition fieldDef)
         {
             var p = cmd.CreateParameter();

src/ServiceStack.OrmLite/OrmLiteWriteCommandExtensions.cs

@@ -907,9 +907,8 @@ internal static void SaveReferences<T, TRef>(this IDbCommand dbCmd, T instance,
         internal static void ExecuteProcedure<T>(this IDbCommand dbCmd, T obj)
         {
             var dialectProvider = dbCmd.GetDialectProvider();
-            string sql = dialectProvider.ToExecuteProcedureStatement(obj);
-            dbCmd.CommandType = CommandType.StoredProcedure;
-            dbCmd.ExecuteSql(sql);
+            dialectProvider.PrepareStoredProcedureStatement(dbCmd, obj);
+            dbCmd.ExecuteNonQuery();
         }
 
         internal static ulong GetRowVersion(this IDbCommand dbCmd, ModelDefinition modelDef, object id)