freesql简单使用操作mysql数据库

news2024/12/27 10:18:48

参考：freesql中文官网指南 | FreeSql 官方文档

这两天准备做一个测试程序，往一个系统的数据表插入一批模拟设备数据，然后还要模拟设备终端发送数据包，看看系统的承压能力。

因为系统使用的第三方框架中用到了freesql，我就想在测试程序中从0开始实验使用freesql来操作数据库。

一、创建wpf工程或者winform工程并创建数据表实体

我创建的是wpf工程，运行的目标框架选择的NET6

数据表实体依据自己需要操作的业务表字段来创建。

二、引入freesql包FreeSql.Provider.MySqlConnector

为什么要用FreeSql.Provider.MySqlConnector ，而不是 FreeSql.Provider.MySql，官网介绍说MySqlConnector比mysql更优。

三、配置连接串

在项目的App.config文件中配置connectionStrings连接串。

Data Source=服务器ip;Port=3306;Database=jqtahmdb;uid=root;pwd=mima;charset=utf8mb4;Allow User Variables=true;AllowLoadLocalInfile=true;SslMode=None;Pooling=true;

四、创建数据库操作类 FreeSqlDb和数据连接操作方法

1、在类中创建一个数据连接方法，返回数据连接对象。

public static IFreeSql ConnectSQL() //连接数据库
        {
            var connectionString = System.Configuration.ConfigurationManager.ConnectionStrings["Mysql"].ToString();//实例化连接对象
            var fsql = new FreeSql.FreeSqlBuilder()
            .UseConnectionString(DataType.MySql, connectionString).UseAutoSyncStructure(false).Build();
            if (fsql != null)
            {
                return fsql; //连接成功返回true
            }
            return fsql;
        }

2、创建数据表操作方法

下面是查询数据和插入数据的方法示例。

public static  List<Enity.TahmCJ_desc> GetDescList(Enity.TahmCJ_desc desc)
        {
            List<Enity.TahmCJ_desc> mylist=new List<Enity.TahmCJ_desc>();
            var fsql = ConnectSQL();
            mylist = fsql.Select<Enity.TahmCJ_desc>()
                .WhereIf(!string.IsNullOrWhiteSpace(desc.TenantId), e => e.TenantId == desc.TenantId)
                .WhereIf(!string.IsNullOrWhiteSpace(desc.channelno), e => e.channelno == desc.channelno)
                .ToList();
            return mylist;
        }

        public static int InsertDesc(Enity.TahmCJ_desc desc)
        {
            if (desc.Id == null)
            {
                desc.Id = Guid.NewGuid();
            }
            desc.CreationTime= DateTime.Now;
            desc.CreatorId = desc.TenantId;
            desc.LastModificationTime= DateTime.Now;
            desc.LastModifierId= desc.TenantId;
            desc.IsDeleted = 0;

            var fsql = ConnectSQL();
            var myEF = fsql.Insert<Enity.TahmCJ_desc>(desc).ExecuteAffrows();
               
            return myEF;
        }