data

yibei333 · Aug 13, 2024 · 9747613 · 9747613
1 parent 2bfcbfc
commit 9747613
Show file tree

Hide file tree

Showing 4 changed files with 57 additions and 2 deletions.
diff --git a/assets/sharpdevlib.data.version.txt b/assets/sharpdevlib.data.version.txt
@@ -1 +1 @@
-2.0.0.5-alpha
+2.0.0.6-alpha
diff --git a/src/SharpDevLib.Data/SharpDevLib.Data.csproj b/src/SharpDevLib.Data/SharpDevLib.Data.csproj
@@ -17,7 +17,7 @@
 		<PackageLicenseExpression>MIT</PackageLicenseExpression>
 		<PackageRequireLicenseAcceptance>True</PackageRequireLicenseAcceptance>
 		<GenerateDocumentationFile>True</GenerateDocumentationFile>
-		<Version>2.0.0.5-alpha</Version>
+		<Version>2.0.0.6-alpha</Version>
 		<GeneratePackageOnBuild>False</GeneratePackageOnBuild>
 		<PackageReadmeFile>README.md</PackageReadmeFile>
 		<AllowUnsafeBlocks>true</AllowUnsafeBlocks>

diff --git a/src/SharpDevLib.Data/SqlHelper.cs b/src/SharpDevLib.Data/SqlHelper.cs
@@ -217,6 +217,43 @@ public async Task<DataSet> ExecuteDataSetAsync(string sql, DbParameter[] paramet
         return await Task.Run(() => ExecuteDataSet(sql, parameters), cancellationToken);
     }
 
+    /// <summary>
+    /// 检索数据表格
+    /// </summary>
+    /// <param name="sql">sql语句</param>
+    /// <param name="parameters">sql参数</param>
+    /// <returns>数据表格</returns>
+    public DataTable ExecuteDataTable(string sql, params DbParameter[] parameters)
+    {
+        var set = ExecuteDataSet(sql, parameters);
+        var table = set.Tables[0];
+        set.Tables.Remove(table);
+        return table;
+    }
+
+    /// <summary>
+    /// 检索数据表格
+    /// </summary>
+    /// <param name="sql">sql语句</param>
+    /// <param name="parameters">sql参数</param>
+    /// <returns>数据表格</returns>
+    public async Task<DataTable> ExecuteDataTableAsync(string sql, params DbParameter[] parameters)
+    {
+        return await Task.Run(() => ExecuteDataTable(sql, parameters));
+    }
+
+    /// <summary>
+    /// 检索数据表格
+    /// </summary>
+    /// <param name="sql">sql语句</param>
+    /// <param name="parameters">sql参数</param>
+    /// <param name="cancellationToken">CancellationToken</param>
+    /// <returns>数据表格</returns>
+    public async Task<DataTable> ExecuteDataTableAsync(string sql, DbParameter[] parameters, CancellationToken cancellationToken)
+    {
+        return await Task.Run(() => ExecuteDataTable(sql, parameters), cancellationToken);
+    }
+
     /// <summary>
     /// 执行非查询sql语句
     /// </summary>

diff --git a/src/SharpDevLib.Tests/Data/SqlHelperTests.cs b/src/SharpDevLib.Tests/Data/SqlHelperTests.cs
@@ -7,6 +7,7 @@
 using SharpDevLib.Tests.TestData.Data;
 using System;
 using System.Collections.Generic;
+using System.Data;
 using System.IO;
 using System.Linq;
 using System.Runtime.CompilerServices;
@@ -111,6 +112,23 @@ public async Task ExecuteDataSetAsyncTest()
         Assert.AreEqual(UserFavorites.Serialize(), dataSet.Tables[1].ToList<UserFavorite>().Serialize());
     }
 
+    [TestMethod]
+    public async Task ExecuteDataTableAsyncTest()
+    {
+        SqlHelper.Config(SqliteFactory.Instance, SourceConnectionString);
+        using var sqlHelper = new SqlHelper();
+
+        var sql = $@"
+            SELECT [Name],Age FROM [User];
+            SELECT [Name],Favorite FROM [UserFavorite];
+            SELECT a.[Name],a.Age,b.Favorite FROM [User] a INNER JOIN [UserFavorite] b ON a.Name=b.Name;
+        ";
+        var table = await sqlHelper.ExecuteDataTableAsync(sql);
+        table.TableName = "xx";
+        var set = new DataSet();
+        set.Tables.Add(table);
+    }
+
     [TestMethod]
     public void ExecuteNoneQueryTest()
     {