SqlSugar 2.入门必看_sqlsugarscope

1.上下文概念

• 同步情况：在同一个线程是同一个上下文
• 异步情况：在同一串await中是一个上下文(await会改变线程，和同步是不一样的)

2.创建对象

2.1 SqlSugarClient

优点：

• 性能比SqlSugarScope有5%的提升

缺点：

• 不能使用单例
• db不能跨上下文使用，每次需要new一个新对象
• 偶发错误难排查，适合有经验的用户

2.1.1 静态方法案例

创建对象：

public class Sugar
    {
        public static SqlSugarClient GetInstance()
        {
            SqlSugarClient db = new SqlSugarClient(new ConnectionConfig()
            {
                DbType = SqlSugar.DbType.MySql,
                ConnectionString = "server = 127.0.0.1; Database = sugarlearn; Uid = root; Pwd = root; AllowLoadLocalInfile = true;",
                InitKeyType = InitKeyType.Attribute,
                IsAutoCloseConnection = true,
                LanguageType= LanguageType.Default
            });

            //每次Sql执行前事件
            db.Aop.OnLogExecuting = (sql, pars) =>
            {
                 	 var queryString = new KeyValuePair<string, SugarParameter[]>(sql, pars);
                     if (sql.StartsWith("UPDATE") || sql.StartsWith("INSERT"))
                     {
                        Console.ForegroundColor = ConsoleColor.Blue;
                        Console.WriteLine($"==============新增/修改操作==============");
                        }
                      if (sql.StartsWith("DELETE"))
                        {
                        Console.ForegroundColor = ConsoleColor.Red;
                        Console.WriteLine($"==============删除操作==============");
                     }
                     if (sql.StartsWith("SELECT"))
                     {
                        Console.ForegroundColor = ConsoleColor.Green;
                        Console.WriteLine($"==============查询操作==============");
                        }
                    //ToSqlExplain 在标题6中有完整代码
                     Console.WriteLine(ToSqlExplain.GetSql(queryString));//输出sql
                     Console.ForegroundColor = ConsoleColor.White;
            };

            //SQL执行完
            db.Aop.OnLogExecuted = (sql, pars) =>
            {
                //执行时间超过1秒
                if (db.Ado.SqlExecutionTime.TotalSeconds > 1)
                {
                    //代码CS文件名
                    var fileName = db.Ado.SqlStackTrace.FirstFileName;
                    //代码行数
                    var fileLine = db.Ado.SqlStackTrace.FirstLine;
                    //方法名
                    var FirstMethodName = db.Ado.SqlStackTrace.FirstMethodName;
                    //sql
                    var exesql = sql;
                    //参数
                    var sqlpars = pars;
                    //db.Ado.SqlStackTrace.MyStackTraceList[1].xxx 获取上层方法的信息
                }
            };

            //SQL报错
            db.Aop.OnError = (exp) =>
            {
                Console.WriteLine(exp.Sql);
                //exp.sql 这样可以拿到错误SQL            
            };
            return db;
        }
    }
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66

调用对象：

static void Main(string[] args)
{
    var db = Sugar.GetInstance();
    bool connect = db.Ado.IsValidConnection(); //验证连接是否成功
    List<Student> list = db.Queryable<Student>().ToList(); //查询Student表中所有数据
    Console.ReadLine();
}
1
2
3
4
5
6
7

2.1.2 SqlSugar.IOC注入案例

创建对象：

//Program.cs中添加如下代码

SugarIocServices.AddSqlSugar(new IocConfig()
{
    //ConfigId="db01"  多租户用到
    ConnectionString = "server=127.0.0.1;Database=ToDoDB;Uid=root;Pwd=root; AllowLoadLocalInfile=true;",
    DbType = IocDbType.MySql,
    IsAutoCloseConnection = true//自动释放
}); //多个库就传List<IocConfig>

//配置参数
SugarIocServices.ConfigurationSugar(db =>
{
    db.Aop.OnLogExecuting = (sql, p) =>
    {
        Console.WriteLine(sql);
    };
    //设置更多连接参数
    //db.CurrentConnectionConfig.XXXX=XXXX
    //db.CurrentConnectionConfig.MoreSettings=new ConnMoreSettings(){}
    //二级缓存设置
    //db.CurrentConnectionConfig.ConfigureExternalServices = new ConfigureExternalServices()
    //{
    // DataInfoCacheService = myCache //配置我们创建的缓存类
    //}
    //读写分离设置
    //laveConnectionConfigs = new List<SlaveConnectionConfig>(){...}

    /*多租户注意*/
    //单库是db.CurrentConnectionConfig 
    //多租户需要db.GetConnection(configId).CurrentConnectionConfig 
});
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

调用对象：

public class TestController : ControllerBase
{
    private static readonly SqlSugarClient db = DbScoped.Sugar;
    
    public TestController()
    {
    }
    
    public JsonResult Test()
    {
        var cs = db.Queryable<Student>().ToList();
        return new JsonResult(cs);
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14

2.1.3 .NET IOC注入案例

注意：SqlSugarClient用 AddScoped 每次请求一个实例

创建对象：

public static class SqlsugarSetup
    {
        public static void AddSqlsugarSetup(this IServiceCollection services)
        {
            SqlSugarClient db = new SqlSugarClient(new ConnectionConfig()
            {
                ConnectionString = "server=127.0.0.1;Database=ToDoDB;Uid=root;Pwd=root; AllowLoadLocalInfile=true;",
                DbType = DbType.MySql,
                IsAutoCloseConnection = true,
            });

            //每次Sql执行前事件
            db.Aop.OnLogExecuting = (sql, pars) =>
            {
                var queryString = new KeyValuePair<string, SugarParameter[]>(sql, pars);
                     if (sql.StartsWith("UPDATE") || sql.StartsWith("INSERT"))
                     {
                        Console.ForegroundColor = ConsoleColor.Blue;
                        Console.WriteLine($"==============新增/修改操作==============");
                        }
                      if (sql.StartsWith("DELETE"))
                        {
                        Console.ForegroundColor = ConsoleColor.Red;
                        Console.WriteLine($"==============删除操作==============");
                     }
                     if (sql.StartsWith("SELECT"))
                     {
                        Console.ForegroundColor = ConsoleColor.Green;
                        Console.WriteLine($"==============查询操作==============");
                        }
                    //ToSqlExplain 在标题6中有完整代码
                     Console.WriteLine(ToSqlExplain.GetSql(queryString));//输出sql
                     Console.ForegroundColor = ConsoleColor.White;
            };

            //每次Sql执行后事件
            db.Aop.OnLogExecuted = (sql, pars) =>
            {
                //执行时间超过10秒
                if (db.Ado.SqlExecutionTime.TotalSeconds > 10)
                {
                    Console.WriteLine(sql);
                }
            };

            //SQL报错
            db.Aop.OnError = (exp) =>
            {
                Console.WriteLine(exp.Sql);
                //exp.sql 这样可以拿到错误SQL            
            };

            services.AddScoped<ISqlSugarClient>(it => { return db; });
        }
    }
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55

Program.cs 依赖注入：

builder.Services.AddSqlsugarSetup();
1

调用对象：

private readonly ISqlSugarClient db;
public ToDoService(ISqlSugarClient _sqlSugarClient)
{
    db = _sqlSugarClient;
}

public void Test()
{
    var list = db.Queryable<Student>();
}
1
2
3
4
5
6
7
8
9
10

2.2 SqlSugarScope

优点：

• 必须使用单例模式
• 推荐没有.NET开发经验的新手使用
• 不用考虑任何线程问题，无脑使用，简单省事，较强性能
  支持同一个上下文共享事务

缺点：

• 不使用单例模式，SqlSugarScope 一直 new 会存在内存泄露问题

2.2.1 静态字段案例

创建对象：

public class Sugar
    {
        public static SqlSugarScope db = new SqlSugarScope(new ConnectionConfig()
        {
            ConnectionString = "server = 127.0.0.1; Database = sugarlearn; Uid = root; Pwd = root; AllowLoadLocalInfile = true;",//连接符字串
            DbType = DbType.MySql,//数据库类型
            IsAutoCloseConnection = true //不设成true要手动close
        },
            db =>
            {
                //调试SQL事件
                db.Aop.OnLogExecuting = (sql, pars) =>
                 {
                     var queryString = new KeyValuePair<string, SugarParameter[]>(sql, pars);
                     if (sql.StartsWith("UPDATE") || sql.StartsWith("INSERT"))
                     {
                        Console.ForegroundColor = ConsoleColor.Blue;
                        Console.WriteLine($"==============新增/修改操作==============");
                        }
                      if (sql.StartsWith("DELETE"))
                        {
                        Console.ForegroundColor = ConsoleColor.Red;
                        Console.WriteLine($"==============删除操作==============");
                     }
                     if (sql.StartsWith("SELECT"))
                     {
                        Console.ForegroundColor = ConsoleColor.Green;
                        Console.WriteLine($"==============查询操作==============");
                        }
                    //ToSqlExplain 在标题6中有完整代码
                     Console.WriteLine(ToSqlExplain.GetSql(queryString));//输出sql
                     Console.ForegroundColor = ConsoleColor.White;
                 };
                db.Aop.OnLogExecuted = (sql, pars) =>
                {
                    //执行时间超过1秒
                    if (db.Ado.SqlExecutionTime.TotalSeconds > 1)
                    {
                        //代码CS文件名
                        var fileName = db.Ado.SqlStackTrace.FirstFileName;
                        //代码行数
                        var fileLine = db.Ado.SqlStackTrace.FirstLine;
                        //方法名
                        var FirstMethodName = db.Ado.SqlStackTrace.FirstMethodName;
                        //sql
                        var exesql = sql;
                        //参数
                        var sqlpars = pars;
                        //db.Ado.SqlStackTrace.MyStackTraceList[1].xxx 获取上层方法的信息
                    }
                };
            });
    }
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53

调用方法一(类调用)：

class Program
    {
        static void Main(string[] args)
        {
            bool connect = Sugar.db.Ado.IsValidConnection(); //验证连接是否成功
            List<Student> list = Sugar.db.Queryable<Student>().ToList(); //查询Student表中所有数据
            Console.ReadLine();
        }
    }
1
2
3
4
5
6
7
8
9

调用方法二(继承方式单例)：

class Program : Sugar
    {
        static void Main(string[] args)
        {
            bool connect = db.Ado.IsValidConnection(); //验证连接是否成功
            List<Student> list = db.Queryable<Student>().ToList(); //查询Student表中所有数据
            Console.ReadLine();
        }
    }
1
2
3
4
5
6
7
8
9

2.2.2 SqlSugar.IOC注入案例

创建对象：

//Program.cs中添加如下代码

SugarIocServices.AddSqlSugar(new IocConfig()
{
    //ConfigId="db01"  多租户用到
    ConnectionString = "server=127.0.0.1;Database=ToDoDB;Uid=root;Pwd=root; AllowLoadLocalInfile=true;",
    DbType = IocDbType.MySql,
    IsAutoCloseConnection = true//自动释放
}); //多个库就传List<IocConfig>

//配置参数
SugarIocServices.ConfigurationSugar(db =>
{
    db.Aop.OnLogExecuting = (sql, p) =>
    {
        Console.WriteLine(sql);
    };
    //设置更多连接参数
    //db.CurrentConnectionConfig.XXXX=XXXX
    //db.CurrentConnectionConfig.MoreSettings=new ConnMoreSettings(){}
    //二级缓存设置
    //db.CurrentConnectionConfig.ConfigureExternalServices = new ConfigureExternalServices()
    //{
    // DataInfoCacheService = myCache //配置我们创建的缓存类
    //}
    //读写分离设置
    //laveConnectionConfigs = new List<SlaveConnectionConfig>(){...}

    /*多租户注意*/
    //单库是db.CurrentConnectionConfig 
    //多租户需要db.GetConnection(configId).CurrentConnectionConfig 
});
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

调用对象：

public class TestController : ControllerBase
{
    private static readonly SqlSugarScope db = DbScoped.SugarScope;
    
    public TestController()
    {
    }
    
    public JsonResult Test()
    {
        var cs = db.Queryable<Student>().ToList();
        return new JsonResult(cs);
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14

2.2.3 .NET IOC注入案例

注意：SqlSugarScope用单例AddSingleton 单例

创建对象：

public static class SqlsugarSetup
    {
        public static void AddSqlsugarSetup(this IServiceCollection services)
        {
            SqlSugarScope sqlSugar = new SqlSugarScope(new ConnectionConfig()
            {
                DbType = SqlSugar.DbType.MySql,
                ConnectionString = "server = 127.0.0.1; Database = ToDoDB; Uid = root; Pwd = root; AllowLoadLocalInfile = true;",
                IsAutoCloseConnection = true,
            },
                db =>
                {
                    //每次Sql执行前事件
                    db.Aop.OnLogExecuting = (sql, pars) =>
                    {
                        var queryString = new KeyValuePair<string, SugarParameter[]>(sql, pars);
                     if (sql.StartsWith("UPDATE") || sql.StartsWith("INSERT"))
                     {
                        Console.ForegroundColor = ConsoleColor.Blue;
                        Console.WriteLine($"==============新增/修改操作==============");
                        }
                      if (sql.StartsWith("DELETE"))
                        {
                        Console.ForegroundColor = ConsoleColor.Red;
                        Console.WriteLine($"==============删除操作==============");
                     }
                     if (sql.StartsWith("SELECT"))
                     {
                        Console.ForegroundColor = ConsoleColor.Green;
                        Console.WriteLine($"==============查询操作==============");
                        }
                    //ToSqlExplain 在标题6中有完整代码
                     Console.WriteLine(ToSqlExplain.GetSql(queryString));//输出sql
                     Console.ForegroundColor = ConsoleColor.White;
                    };

                    //SQL执行完
                    db.Aop.OnLogExecuted = (sql, pars) =>
                    {
                        //执行时间超过1秒
                        if (db.Ado.SqlExecutionTime.TotalSeconds > 1)
                        {
                            //代码CS文件名
                            var fileName = db.Ado.SqlStackTrace.FirstFileName;
                            //代码行数
                            var fileLine = db.Ado.SqlStackTrace.FirstLine;
                            //方法名
                            var FirstMethodName = db.Ado.SqlStackTrace.FirstMethodName;
                            //sql
                            var exesql = sql;
                            //参数
                            var sqlpars = pars;
                            //db.Ado.SqlStackTrace.MyStackTraceList[1].xxx 获取上层方法的信息
                        }
                    };

                    //SQL报错
                    db.Aop.OnError = (exp) =>
                    {
                        Console.WriteLine(exp.Sql);
                        //exp.sql 这样可以拿到错误SQL            
                    };
                });
            services.AddSingleton<ISqlSugarClient>(sqlSugar);//这边是SqlSugarScope用AddSingleton
        }
    }
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66

Program.cs 依赖注入：

builder.Services.AddSqlsugarSetup();
1

调用对象：

private readonly ISqlSugarScope db;
public ToDoService(ISqlSugarClient _sqlSugarScope)
{
    db = _sqlSugarScope;
}

public void Test()
{
    var list = db.Queryable<Student>();
}
1
2
3
4
5
6
7
8
9
10

3.连接参数

4.设置超时时间

默认是30秒

• 方法一：在连接字符串中添加 Connect Timeout=30；
• 方法二：创建对象中添加代码

db.Ado.CommandTimeOut = 30;//单位秒
1

5.验证连接是否成功

//true：代表连接成功
bool connect = db.Ado.IsValidConnection(); 
1
2

6.打印Sql

Sql执行前的事件
在 db.Aop.OnLogExecuting 中拼接出完整Sql

 //每次Sql执行前事件
db.Aop.OnLogExecuting = (sql, pars) =>
{
    var queryString = new KeyValuePair<string, SugarParameter[]>(sql, pars);
    //ToSqlExplain 在标题6中有完整代码
    Console.WriteLine(ToSqlExplain.GetSql(queryString));//输出sql
};
1
2
3
4
5
6
7

ToSqlExplain.GetSql类中的方法(拼接出完整的Sql，方便查看)

public class ToSqlExplain
    {
        public static string GetSql(KeyValuePair<string, SugarParameter[]> queryString)
        {
            var sql = queryString.Key;//sql语句
            var par = queryString.Value;//参数

            //字符串替换MethodConst1x会替换掉MethodConst1所有要从后往前替换,不能用foreach,后续可以优化
            for (int i = par.Length - 1; i >= 0; i--)
            {
                if (par[i].ParameterName.StartsWith("@") && par[i].ParameterName.Contains("UnionAll"))
                {
                    sql = sql.Replace(par[i].ParameterName, par[i].Value.ToString());
                }
            }

            for (int i = par.Length - 1; i >= 0; i--)
            {
                if (par[i].ParameterName.StartsWith("@Method"))
                {
                    sql = sql.Replace(par[i].ParameterName, "'" + par[i].Value.ToString() + "'");
                }
            }
            for (int i = par.Length - 1; i >= 0; i--)
            {
                if (par[i].ParameterName.StartsWith("@Const"))
                {
                    sql = sql.Replace(par[i].ParameterName, par[i].Value.ToString());
                }
            }
            for (int i = par.Length - 1; i >= 0; i--)
            {
                if (par[i].ParameterName.StartsWith("@"))
                {
                    //值拼接单引号 拿出来的sql不会报错
                    sql = sql.Replace(par[i].ParameterName, "'" + Convert.ToString(par[i].Value) + "'");
                }
            }
            return sql;
        }
    }
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41

7.国际化

创建对象的时候指定语言

• 枚举说明

public enum LanguageType
    {
        Default=0, //中&英
        Chinese=1, //处理过的异常尽量中文,未处理的还是英文
        English=2 //全部英文
    }
1
2
3
4
5
6

• 用法：

SqlSugarClient db = new SqlSugarClient(new ConnectionConfig()
  {
                ConnectionString = Config.ConnectionString,
                DbType = DbType.SqlServer,
                LanguageType=LanguageType.English,//只显示英文
                IsAutoCloseConnection = true 
   });
1
2
3
4
5
6
7

8.长连接、短连接用法

8.1 自动释放(短连接，推荐这样使用)

• 不需要再去写 Using 或者 Open 或者 Close
• 没有事务的情况，每次操作自动调用 Open 或者 Close
• 有事务的情况下，开启事务调用 Open ,提交或回滚事务调用 Close

IsAutoCloseConnection = true//自动释放
1

8.2 如何使用长连接

• 事务中默认是长连接，结束后会自动关闭
• 创建对象的时候，IsAutoCloseConnection = false 即是手动释放
• 自动释放模式中，不使用事务的情况，可以使用 OpenAlways实现长连接

//5.0.6.3
 using (db.Ado.OpenAlways()) 
 {
     db.Queryable...
     db.Insertable...
 }
1
2
3
4
5
6

8.3 使用场景

• 插入一个局部临时表，如果不在一个会话中，查询不到，这时候可以将临时表操作和之后的操作放在一起，使用 db.Ado.OpenAlways() 实现长连接

9.配置最小时间

针对时间类型的字段
推荐还是使用默认的，这样多种数据库使用不会报错
如果需要强制指定，再添加此代码

//5.0.8.1
db.CurrentConnectionConfig.MoreSettings = new ConnMoreSettings
  {
        DbMinDate = DateTime.MinValue//默认最小时间是 1900-01-01 00:00:00.000 
   };
1
2
3
4
5