Add SqlConcat,SqlCurrency + refactor SqlExpression to use it

Author: mythz

src/ServiceStack.OrmLite.Firebird/FirebirdOrmLiteDialectProvider.cs

@@ -801,6 +801,8 @@ public override void DropColumn(IDbConnection db, Type modelType, string columnN
 
             db.ExecuteSql(command);
         }
+
+        public override string SqlConcat(IEnumerable<object> args) => string.Join(" || ", args);
     }
 }
 

src/ServiceStack.OrmLite.Firebird/FirebirdSqlExpression.cs

@@ -30,11 +30,6 @@ protected override object VisitColumnAccessMethod(MethodCallExpression m)
             }
             return new PartialSqlString(statement);
         }
-
-        protected override PartialSqlString ToConcatPartialString(List<object> args)
-        {
-            return new PartialSqlString(string.Join(" || ", args));
-        }
     }
 }
 

src/ServiceStack.OrmLite.MySql/MySqlDialectProvider.cs

@@ -208,6 +208,9 @@ public string GetColumnDefinition(FieldDefinition fieldDef)
             return ret;
         }
 
+        public override string SqlCurrency(string fieldOrValue, string currencySymbol) => 
+            SqlConcat(new []{ "'" + currencySymbol + "'", "format(" + fieldOrValue + ",2)"});
+
         protected MySqlConnection Unwrap(IDbConnection db)
         {
             return (MySqlConnection)db.ToDbConnection();

src/ServiceStack.OrmLite.MySql/MySqlExpression.cs

@@ -1,18 +1,10 @@
-using System.Collections.Generic;
-using System.Linq.Expressions;
-
-namespace ServiceStack.OrmLite.MySql
+namespace ServiceStack.OrmLite.MySql
 {
     public class MySqlExpression<T> : SqlExpression<T>
     {
         public MySqlExpression(IOrmLiteDialectProvider dialectProvider)
             : base(dialectProvider) {}
 
-        protected override PartialSqlString ToConcatPartialString(List<object> args)
-        {
-            return new PartialSqlString($"CONCAT({string.Join(", ", args)})");
-        }
-
         protected override string ToCast(string quotedColName)
         {
             return $"cast({quotedColName} as char(1000))";

src/ServiceStack.OrmLite.Oracle/OracleOrmLiteDialectProvider.cs

@@ -1084,5 +1084,7 @@ public override string ToRowCountStatement(string innerSql)
         {
             return "SELECT COUNT(*) FROM ({0})".Fmt(innerSql);
         }
+
+        public override string SqlConcat(IEnumerable<object> args) => string.Join(" || ", args);
     }
 }

src/ServiceStack.OrmLite.Oracle/OracleSqlExpression.cs

@@ -52,11 +52,6 @@ public override SqlExpression<T> OrderByRandom()
         {
             return base.OrderBy("dbms_random.value");
         }
-
-        protected override PartialSqlString ToConcatPartialString(List<object> args)
-        {
-            return new PartialSqlString(string.Join(" || ", args));
-        }
     }
 }
 

src/ServiceStack.OrmLite.PostgreSQL/PostgreSQLDialectProvider.cs

@@ -313,6 +313,11 @@ public override void PrepareStoredProcedureStatement<T>(IDbCommand cmd, T obj)
             SetParameterValues<T>(cmd, obj);
         }
 
+        public override string SqlConcat(IEnumerable<object> args) => string.Join(" || ", args);
+
+        public override string SqlCurrency(string fieldOrValue, string currencySymbol) => currencySymbol == "$"
+            ? fieldOrValue + "::text::money::text"
+            : "replace(" + fieldOrValue + "::text::money::text,'$','" + currencySymbol + "')";
 
         protected NpgsqlConnection Unwrap(IDbConnection db)
         {

src/ServiceStack.OrmLite.PostgreSQL/PostgreSqlExpression.cs

@@ -1,4 +1,3 @@
-using System.Collections.Generic;
 using System.Linq;
 
 namespace ServiceStack.OrmLite.PostgreSQL
@@ -25,11 +24,6 @@ public override SqlExpression<T> OrderByRandom()
         {
             return base.OrderBy("RANDOM()");
         }
-
-        protected override PartialSqlString ToConcatPartialString(List<object> args)
-        {
-            return new PartialSqlString(string.Join(" || ", args));
-        }
     }
 
 }

src/ServiceStack.OrmLite.SqlServer/SqlServerOrmLiteDialectProvider.cs

@@ -355,6 +355,9 @@ public override string GetLoadChildrenSubSelect<From>(SqlExpression<From> expr)
             return base.GetLoadChildrenSubSelect(expr);
         }
 
+        public override string SqlCurrency(string fieldOrValue, string currencySymbol) => 
+            SqlConcat(new[] { "'" + currencySymbol + "'", $"CONVERT(VARCHAR, CONVERT(MONEY, {fieldOrValue}), 1)" });
+
         protected SqlConnection Unwrap(IDbConnection db) => (SqlConnection)db.ToDbConnection();
 
         protected SqlCommand Unwrap(IDbCommand cmd) => (SqlCommand)cmd.ToDbCommand();

src/ServiceStack.OrmLite.Sqlite/SqliteExpression.cs

@@ -76,10 +76,5 @@ public override SqlExpression<T> OrderByRandom()
         {
             return base.OrderBy("random()");
         }
-
-        protected override PartialSqlString ToConcatPartialString(List<object> args)
-        {
-            return new PartialSqlString(string.Join(" || ", args));
-        }
     }
 }