Merge pull request #304 from devrios/master

Added support for NonQuery to get affected rows

Author: mythz

src/ServiceStack.OrmLite/OrmLiteReadConnectionExtensions.cs

@@ -160,6 +160,21 @@ public static List<T> Query<T>(this IDbConnection dbConn, string sql, Dictionary
             return dbConn.Exec(dbCmd => dbCmd.Query<T>(sql, dict));
         }
 
+        public static int ExecuteNonQuery(this IDbConnection dbConn, string sql)
+        {
+            return dbConn.Exec(dbCmd => dbCmd.ExecuteNonQuery(sql));
+        }
+
+        public static int ExecuteNonQuery(this IDbConnection dbConn, string sql, object anonType)
+        {
+            return dbConn.Exec(dbCmd => dbCmd.ExecuteNonQuery(sql, anonType));
+        }
+
+        public static int ExecuteNonQuery(this IDbConnection dbConn, string sql, Dictionary<string, object> dict)
+        {
+            return dbConn.Exec(dbCmd => dbCmd.ExecuteNonQuery(sql, dict));
+        }
+
         public static T QueryScalar<T>(this IDbConnection dbConn, object anonType)
         {
             return dbConn.Exec(dbCmd => dbCmd.QueryScalar<T>(anonType));

src/ServiceStack.OrmLite/OrmLiteReadExtensions.cs

@@ -253,7 +253,36 @@ private static void SetParameters<T>(this IDbCommand dbCmd, object anonType, boo
                 p.Value = value ?? DBNull.Value;
 				dbCmd.Parameters.Add(p);
 			}
-		}
+		}
+
+        private static void SetParameters(this IDbCommand dbCmd, object anonType, bool excludeNulls)
+        {
+            dbCmd.Parameters.Clear();
+            lastQueryType = null;
+            if (anonType == null)
+                return;
+
+            var pis = anonType.GetType().GetSerializableProperties();
+
+            foreach (var pi in pis)
+            {
+                var mi = pi.GetGetMethod();
+                if (mi == null)
+                    continue;
+
+                var value = mi.Invoke(anonType, new object[0]);
+                if (excludeNulls && value == null)
+                    continue;
+
+                var p = dbCmd.CreateParameter();
+
+                p.ParameterName = pi.Name;
+                p.DbType = OrmLiteConfig.DialectProvider.GetColumnDbType(pi.PropertyType);
+                p.Direction = ParameterDirection.Input;
+                p.Value = value ?? DBNull.Value;
+                dbCmd.Parameters.Add(p);
+            }
+        }	
 
 		private static void SetParameters(this IDbCommand dbCmd, Dictionary<string,object> dict, bool excludeNulls)
 		{
@@ -393,7 +422,25 @@ internal static List<T> Query<T>(this IDbCommand dbCmd, string sql, Dictionary<s
 				return IsScalar<T>()
 					? dbReader.GetFirstColumn<T>()
 					: dbReader.ConvertToList<T>();
-		}
+		}
+
+        internal static int ExecuteNonQuery(this IDbCommand dbCmd, string sql, object anonType = null)
+        {
+            if (anonType != null)
+                dbCmd.SetParameters(anonType, excludeNulls: false);
+            dbCmd.CommandText = sql;
+
+            return dbCmd.ExecuteNonQuery();
+        }
+
+        internal static int ExecuteNonQuery(this IDbCommand dbCmd, string sql, Dictionary<string, object> dict)
+        {
+            if (dict != null)
+                dbCmd.SetParameters(dict, excludeNulls: false);
+            dbCmd.CommandText = sql;
+
+            return dbCmd.ExecuteNonQuery();
+        }
 
 	    internal static T QueryScalar<T>(this IDbCommand dbCmd, object anonType)
 		{