Add TdengineCore

2025-09-20 10:38:09 +08:00 · 2023-07-30 22:19:03 +08:00
parent 4f71c84f19
commit 2f1c8790c0
24 changed files with 3469 additions and 0 deletions
--- a/Src/Asp.NetCore2/SqlSugar.TDengineCore/TDengine/TDengineProvider.cs
+++ b/Src/Asp.NetCore2/SqlSugar.TDengineCore/TDengine/TDengineProvider.cs
@@ -0,0 +1,104 @@
+using System;
+using System.Collections.Generic;
+using System.Data;
+using System.Data.Common;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using SqlSugar.TDengineAdo;
+namespace SqlSugar.TDengine
+{
+    public partial class TDengineProvider : AdoProvider
+    {
+        public TDengineProvider() 
+        {
+            
+         
+        }
+        public override IDbConnection Connection
+        {
+            get
+            {
+                if (base._DbConnection == null)
+                {
+                    try
+                    { 
+                        var TDengineConnectionString = base.Context.CurrentConnectionConfig.ConnectionString;
+                        base._DbConnection = new TDengineConnection(TDengineConnectionString);
+                    }
+                    catch (Exception)
+                    {
+                        throw;
+
+                    }
+                }
+                return base._DbConnection;
+            }
+            set
+            {
+                base._DbConnection = value;
+            }
+        }
+
+        public override void BeginTran(string transactionName)
+        {
+          
+        }
+        /// <summary>
+        /// Only SqlServer
+        /// </summary>
+        /// <param name="iso"></param>
+        /// <param name="transactionName"></param>
+        public override void BeginTran(IsolationLevel iso, string transactionName)
+        {
+        
+        }
+        public override IDataAdapter GetAdapter()
+        {
+            return new SqlSugar.TDengineCore.TDengineDataAdapter();
+        }
+        public override DbCommand GetCommand(string sql, SugarParameter[] parameters)
+        {
+            TDengineCommand sqlCommand = new TDengineCommand(sql, (TDengineConnection)this.Connection);
+            sqlCommand.CommandType = this.CommandType;
+            sqlCommand.CommandTimeout = this.CommandTimeOut;
+            //if (this.Transaction != null)
+            //{
+            //    sqlCommand.Transaction = (TDengineTransaction)this.Transaction;
+            //}
+            if (parameters.HasValue())
+            {
+                IDataParameter[] ipars = ToIDbDataParameter(parameters);
+                sqlCommand.Parameters.AddRange((TDengineParameter[])ipars);
+            }
+            CheckConnection();
+            return sqlCommand;
+        }
+        public override void SetCommandToAdapter(IDataAdapter dataAdapter, DbCommand command)
+        {
+            ((TDengineDataAdapter)dataAdapter).SelectCommand = (TDengineCommand)command;
+        }
+        /// <summary>
+        /// if mysql return MySqlParameter[] pars
+        /// if sqlerver return SqlParameter[] pars ...
+        /// </summary>
+        /// <param name="parameters"></param>
+        /// <returns></returns>
+        public override IDataParameter[] ToIDbDataParameter(params SugarParameter[] parameters)
+        {
+            if (parameters == null || parameters.Length == 0) return null;
+            TDengineParameter[] result = new TDengineParameter[parameters.Length];
+            int i = 0;
+            foreach (var parameter in parameters)
+            {
+                if (parameter.Value == null) parameter.Value = DBNull.Value;
+                 
+                var sqlParameter = new TDengineParameter(parameter.ParameterName,parameter.Value,parameter.DbType,0);
+                result[0]=sqlParameter;
+                i++;
+            }
+            return result;
+        }
+         
+    }
+}