src/Datory/Utils/DbUtils.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

using SqlKata.Compilers;
using Datory.DatabaseImpl;

namespace Datory.Utils
{
    public static class DbUtils
    {
        public const int VarCharDefaultLength = 500;

        internal static Compiler GetCompiler(DatabaseType databaseType, string connectionString)
        {
            Compiler compiler = null;

            if (databaseType == DatabaseType.MySql)
            {
                compiler = MySqlImpl.Instance.GetCompiler(connectionString);
            }
            else if (databaseType == DatabaseType.SqlServer)
            {
                compiler = SqlServerImpl.Instance.GetCompiler(connectionString);
            }
            else if (databaseType == DatabaseType.PostgreSql)
            {
                compiler = PostgreSqlImpl.Instance.GetCompiler(connectionString);
            }
            else if (databaseType == DatabaseType.SQLite)
            {
                compiler = SQLiteImpl.Instance.GetCompiler(connectionString);
            }

            return compiler;
        }

        internal static string ColumnIncrement(DatabaseType databaseType, string columnName, int plusNum = 1)
        {
            var retVal = string.Empty;

            if (databaseType == DatabaseType.MySql)
            {
                retVal = MySqlImpl.Instance.ColumnIncrement(columnName, plusNum);
            }
            else if (databaseType == DatabaseType.SqlServer)
            {
                retVal = SqlServerImpl.Instance.ColumnIncrement(columnName, plusNum);
            }
            else if (databaseType == DatabaseType.PostgreSql)
            {
                retVal = PostgreSqlImpl.Instance.ColumnIncrement(columnName, plusNum);
            }
            else if (databaseType == DatabaseType.SQLite)
            {
                retVal = SQLiteImpl.Instance.ColumnIncrement(columnName, plusNum);
            }

            return retVal;
        }

        internal static string ColumnDecrement(DatabaseType databaseType, string columnName, int minusNum = 1)
        {
            var retVal = string.Empty;