1

.NET下数据库的负载均衡(有趣实验)(续) - 王者天涯

 1 year ago
source link: https://www.cnblogs.com/dotnet-college/p/16759726.html
Go to the source link to view the article. You can view the picture content, updated content and better typesetting reading experience. If the link is broken, please click the button below to view the snapshot at that time.

.NET下数据库的负载均衡(有趣实验)(续)

.NET下数据库的负载均衡(有趣实验)这篇文章发表后，受到了众多读者的关注与好评，其中不乏元老级程序员。

读者来信中询问最多的一个问题是：它是否能支持“异种数据库”的负载均衡？？

今天就在此统一回复：能（暂时只能在.Net6版本下实现。.Net Framwork版本后续会再实现。）

下面就通过一个例子，给出实现“异种数据库”负载均衡的两种方法。

首先，把配置负载均衡策略的ds.xml文件修改为多个异种数据库，如下：

<?xml version="1.0" encoding="utf-8" ?>
<DeveloperSharp>
    <DatabaseClusterList>
        <DatabaseCluster Id="StudentData">
            <Database Id="A1" Enable="true" Weight="100" DatabaseType="SqlServer" ConnectionString="Server=localhost;Database=YZZ;Uid=sa;Pwd=123"/>
            <Database Id="A2" Enable="true" Weight="100" DatabaseType="MySql" ConnectionString="Host=localhost;Database=YZZ;User Id=root;password=123"/>
            <Database Id="A3" Enable="true" Weight="100" DatabaseType="PostgreSql" ConnectionString="Server=127.0.0.1;Database=YZZ;Port=5432;User Id=postgres;Password=123;"/>
        </DatabaseCluster>
    </DatabaseClusterList> 
</DeveloperSharp> 

说明：以上配置了异种的Sql Server、MySql、PostgreSql三个数据库来做负载均衡。

SLB.IDA.ConnectionString //数据库链接字符串 
SLB.IDA.DatabaseType     //数据库类型

无论你的数据库访问工具是Entity Framework、Dapper、SqlSugar、FreeSql、等等，只要有了如上两个参数，你就能自行实现相应的数据库操作。

（注：看懂本文思路的前提，是你已经阅读过.NET下数据库的负载均衡(有趣实验)这篇文章）

var IDA = SLB.IDA;
//接下来，直接通过IDA进行各类数据库操作

【示例1：查询】

下面，首先直接给出一个“查询多数据+选出单数据+参数”的使用示例，代码如下：

   //查询多数据
   var Students1 = IDA.SqlExecute<stu>("select * from t_Student");

   //查询多数据（带参数）
   var IdMin = IDA.CreateParameterInput("IdMin", DbType.Int32, 2);
   var LikeName = IDA.CreateParameterInput("LikeName", DbType.String, 50, "%周%");
   var Students2 = IDA.SqlExecute<stu>("select * from t_Student where Id>@IdMin and Name like @LikeName", IdMin, LikeName);
   //另一种写法
   var Students3 = IDA.SqlExecute<stu>("select * from t_Student").Where(t => t.Id > 2 && t.Name.Contains("周"));

   //选出单数据
   var OneStudent = Students2.FirstOrDefault();

其中stu实体类代码如下形式：

public class stu
{
        public int Id { get; set; }
        public string Name { get; set; }
        public int Age { get; set; }
}
//此实体类中的Id、Name、Age属性名，要与数据表中的Id、Name、Age字段名对应

注意：创建参数时使用DbType类型，就是为了能在不同类型数据库（SqlServer、MySql、Oracle、等）之间透明切换！

【示例2：分页】

承接上面“示例1”的代码，若我们要对Students1、Students2进行分页操作（比如：每页20条，取出第5页），相关代码如下：

using DeveloperSharp.Extension;//调用“分页功能”需要引用此命名空间
--------------------------

   var Page1 = Students1.PagePartition(20, 5);
   var Page2 = Students2.PagePartition(20, 5);

   //一气呵成的写法
   var Page3 = IDA.SqlExecute<stu>("select * from t_Student").PagePartition(20, 5);

【示例3：增/删/改】

前面谈完“查询”，我们接下来谈谈“增/删/改”的使用方式，下面是一个“修改数据+参数+事务”的使用示例：

   try
   {
       //开启事务
       IDA.TransactionBegin();

       //修改数据（多语句）
       int affectedRows1 = IDA.SqlExecute("insert into t_Student(Name,Age)values('ww','96');update t_Student set Age=100 where Id=1006");

       //修改数据（带参数）
       var NewAge = IDA.CreateParameterInput("NewAge", DbType.Int32, 200);
       var NewName = IDA.CreateParameterInput("NewName", DbType.String, 50, "孙悟空");
       int affectedRows2 = IDA.SqlExecute("insert into t_Student(Name,Age)values(@NewName,@NewAge)", NewName, NewAge);

       //完成事务
       IDA.TransactionCommit();
   }
   catch
   {
       //回滚事务
       IDA.TransactionRollBack();
   }

【示例4：其它】

最后，我们给出一个“聚合函数+输出参数”的使用示例，代码如下：

   var IdMax = IDA.CreateParameterInput("IdMax", DbType.Int32, 20);
   var TotalCount = IDA.CreateParameterOutput("TotalCount", DbType.Int32);//此项为输出参数
   var Students3 = IDA.SqlExecute<stu>("select @TotalCount=count(*) from t_Student where Id<@IdMax", TotalCount, IdMax);
   int tc = (int)TotalCount.Value;

灵活学习+使用以上4个示例，就能满足几乎所有的数据操作需求。

另外，你有没有发现，上述所有的数据操作几乎只用了一个方法来实现：SqlExecute/ SqlExecute<T>

IDA内功能方法详细说明（辅助参考）：

SqlExecute<T>
声明：IEnumerable<T> SqlExecute<T>(string cmdText, params IDataParameter[] Params) where T : class, new()
用途：执行Sql语句(Select类)
参数：（1）string  cmdText              --  Sql语句
     （2）params IDataParameter[] Params --  参数组
返回：IEnumerable<T> --  多数据结果集


SqlExecute
声明：int SqlExecute(string cmdText, params IDataParameter[] Params)
用途：执行Sql语句(Insert/Update/Delete类)
参数：（1）string  cmdText              --  Sql语句
     （2）params IDataParameter[] Params --  参数组
返回：int --  受影响的行数

SpExecute<T>
声明：IEnumerable<T> SpExecute<T>(string cmdText, params IDataParameter[] Params) where T : class, new()
用途：执行Sp存储过程(Select类)
参数：（1）string  cmdText              --  Sp存储过程名
     （2）params IDataParameter[] Params --  参数组
返回：IEnumerable<T> --  多数据结果集

SpExecute
声明：int SpExecute(string cmdText, params IDataParameter[] Params)
用途：执行Sp存储过程(Insert/Update/Delete类)
参数：（1）string  cmdText              --  Sp存储过程名
     （2）params IDataParameter[] Params --  参数组
返回：int --  受影响的行数

技术交流/支持，请微信扫描二维码，备注“进群”！

2658160-20211213025953948-705694269.jpg

report

Recommend

About Joyk


Aggregate valuable and interesting links.
Joyk means Joy of geeK