c# 实现sql查询DataTable数据集对接SqlSugar ORM-Toy模板网

这篇具有很好参考价值的文章主要介绍了c# 实现sql查询DataTable数据集对接SqlSugar ORM。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

有时候对于已经查询到的数据集，想要进行二次筛选或者查询，还得再查一遍数据库

或者其他的一些逻辑处理不太方便，就想着为什么不能直接使用sql来查询DataTable呢？

搜索全网没找到可用方案，所以自己实现了一个。

主要实现思路是使用 SQLite In-Memory Database 内存数据库，

需要的包主要是

System.Data.SQLite

和 SqlSugar

代码如下

using SqlSugar;
using System;
using System.Collections.Generic;
using System.Data;
using System.Data.SQLite;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace SQLiteHelper
{
    public static class SQLiteHelper
    {
    	public static SqlSugarClient getToSQLiteInMemorySqlSugar(DataTable dt)
        {
            SQLiteConnection conn = SQLiteHelper.ToSQLiteInMemory(dt);
            //创建配置并指定连接字符串
            var config = new ConnectionConfig()
            {
                ConnectionString = conn.ConnectionString,
                DbType = SqlSugar.DbType.Sqlite
            };

            //创建SqlSugarClient
            var db = new SqlSugarClient(config);

            //手动指定底层连接为已有的SQLite连接
            db.Ado.Connection = conn;

            return db;
        }

        private static string GetSQLiteType(Type t)
        {
            if (t == typeof(string)) return "TEXT";
            else if (t == typeof(int)) return "INTEGER";
            else if (t == typeof(double)) return "REAL";
            else if (t == typeof(decimal)) return "NUMERIC";
            else return "BLOB";
        }
        
        private static SQLiteConnection ToSQLiteInMemory(DataTable dt)
        {

            // 创建SQLite in-memory数据库连接
            SQLiteConnection conn = new SQLiteConnection("Data Source=:memory:");
            conn.Open();

            // 创建表结构
            SQLiteCommand cmd = conn.CreateCommand();
            string createTableSql = $"CREATE TABLE {dt.TableName} (";
            foreach (DataColumn col in dt.Columns)
            {
                createTableSql += $"{col.ColumnName} {GetSQLiteType(col.DataType)}, ";
            }
            createTableSql = createTableSql.TrimEnd(',', ' ');
            createTableSql += ")";

            cmd.CommandText = createTableSql;
            cmd.ExecuteNonQuery();

            // 将DataTable bulk insert到SQLite表中
            using (SQLiteTransaction tran = conn.BeginTransaction())
            {
                using (SQLiteCommand insertCmd = new SQLiteCommand(conn))
                {
                    insertCmd.CommandText = $"INSERT INTO {dt.TableName} VALUES({string.Join(",", dt.Columns.Cast<DataColumn>().Select(x => "@" + x.ColumnName))})";

                    foreach (DataRow row in dt.Rows)
                    {
                        foreach (DataColumn col in dt.Columns)
                        {
                            insertCmd.Parameters.AddWithValue("@" + col.ColumnName, row[col.ColumnName]);
                        }
                        insertCmd.ExecuteNonQuery();
                        insertCmd.Parameters.Clear();
                    }
                    tran.Commit();
                }
            }

            return conn;
        }

        

    }
}

调用示例

			// 创建DataTable,添加列
            DataTable dt = new DataTable("Products");
            dt.Columns.Add("Id", typeof(int));
            dt.Columns.Add("Name", typeof(string));
            dt.Columns.Add("Price", typeof(decimal));


            // 填充几行数据
            dt.Rows.Add(1, "Apple", 1.99m);
            dt.Rows.Add(2, "Orange", 2.99m);
            dt.Rows.Add(3, "Banana", 0.99m);
            var db = SQLiteHelper.getToSQLiteInMemorySqlSugar(dt);
			//查询结果
            var ret = db.Ado.SqlQuery<dynamic>("select * from Products").ToList();

这样就实现了sql查询DataTable的功能

原创不易，能帮到你的话，关注，评论，点赞，收藏走一波。文章来源地址https://www.toymoban.com/news/detail-663024.html

到了这里，关于c# 实现sql查询DataTable数据集对接SqlSugar ORM的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！