【腾讯云TDSQL-C Serverless 产品测评】一场ServerLess方案和Native方案的小PK！

<ItemGroup>
  <PackageReference Include="Microsoft.AspNetCore.Mvc.Razor.RuntimeCompilation" Version="6.0.21" />
  <PackageReference Include="Microsoft.EntityFrameworkCore.Tools" Version="7.0.10">
    <PrivateAssets>all</PrivateAssets>
    <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
  </PackageReference>
  <PackageReference Include="Pomelo.EntityFrameworkCore.MySql" Version="7.0.0" />
  <PackageReference Include="ShardingCore" Version="7.7.1.13" />
  <PackageReference Include="Spectre.Console" Version="0.47.0" />
  <PackageReference Include="Yitter.IdGenerator" Version="1.0.14" />
</ItemGroup>

public class Examination
{
    //主键，采用Yitid插件提供的数字生成器ID
	public string Id { get; set; }=YitIdHelper.NextId().ToString();
    
    public List<Paper> Papers { get; set; } = new List<Paper> { };
	
    //其他属性，节约篇幅这里就不一一列举了
    ...
}

public class Paper
{
    //主键，采用Yitid插件提供的数字生成器ID
	public string Id { get; set; }=YitIdHelper.NextId().ToString();
	
    public Examination Examination { get; set; }
	
    //显示声明考试id外键 
	public string ExaminationId { get; set; } = "";
    
    //其他属性，节约篇幅这里就不一一列举了
    ...
}

public class ExaminationEntityConfig:IEntityTypeConfiguration<Examination>
{
    public void Configure(EntityTypeBuilder<Examination> builder)
    {
        builder.ToTable(nameof(Examination));
        builder.HasKey(x => x.Id);
        //...
    }
}

public class PaperEntityConfig : IEntityTypeConfiguration<Paper>
{
    public void Configure(EntityTypeBuilder<Paper> builder)
    {
        builder.ToTable(nameof(Paper));
        builder.HasKey(p => p.Id);
        //设定1对多关联关系，并声明外键Id
        builder.HasOne<Examination>(e => e.Examination).WithMany(p => p.Papers).IsRequired().HasForeignKey(p => p.ExaminationId);
    	//...
    }
}

public class MyDbContext:AbstractShardingDbContext,IShardingTableDbContext
{
    public MyDbContext(DbContextOptions<MyDbContext> options) : base(options) 
    { }

    protected override void OnModelCreating(ModelBuilder modelBuilder)
    {
        base.OnModelCreating(modelBuilder);
        modelBuilder.ApplyConfigurationsFromAssembly(this.GetType().Assembly);
    }

    /// <summary>
    /// 分表路由的尾部命名规则，默认是{表名}_{从大到小的索引}
    /// </summary>
    public IRouteTail RouteTail { get; set; }
}

 /// <summary>
 /// 创建虚拟路由
 /// 该路由为简单的取模hash路由,分表字段是string类型,接受3个参数，第一个参数表示后缀的位数,第二位表示取模的基数，第三位是取模后缀不足的左补字符.
 /// </summary>
 public class PaperVirtualTableRoute : AbstractSimpleShardingModKeyStringVirtualTableRoute<Paper>
 {
     public PaperVirtualTableRoute() : base(2, 3)
     {
     }

     public override void Configure(EntityMetadataTableBuilder<Paper> builder)
     {
         builder.ShardingProperty(o => o.Id);
         builder.AutoCreateTable(null);
         builder.TableSeparator("_");
     }
 }

public static WebApplicationBuilder SetupServices(this WebApplicationBuilder builder)
{
     _configuration = builder.Configuration;
     builder.Services.ConfigureMvc();
     //..其他服务
     return builder;
}
private static void ConfigureSharding(this IServiceCollection services)
{            
    //添加分片配置
    services.AddShardingDbContext<MyDbContext>()
        .UseRouteConfig(op =>
        {
            op.AddShardingTableRoute<PaperVirtualTableRoute>();
        }).UseConfig((sp, op) =>
        {
            var serverVersion = new MySqlServerVersion(new Version(8, 0));
            op.UseShardingQuery((conn, builder) =>
            {
                builder.UseMySql(conn, serverVersion);
            });
            op.UseShardingTransaction((conn, builder) =>
            {
                builder.UseMySql(conn,serverVersion);
            });
            op.AddDefaultDataSource(Guid.NewGuid().ToString("n"),_configuration.GetConnectionString("DefaultConnection")
               );
        }).AddShardingCore();
}

[Route("[controller]/[action]")]
public class TestController : Controller
{
    private readonly ILogger<TestController> _logger;
    private readonly MyDbContext _ctx;
    public TestController(ILogger<TestController> logger, MyDbContext ctx)
    {
        _logger = logger;
        _ctx = ctx;
    }

    public async Task<IActionResult> QuerySimple() 
    {
       //模拟简单查询
        //代码略
    }

    public async Task<IActionResult> QueryComplex()
    {
        //模拟复杂查询
        //代码略
    }

    public async Task<IActionResult> Insert()
    {
        //模拟插入
        //代码略
    }    
}

<ThreadGroup guiclass="ThreadGroupGui" testclass="ThreadGroup" testname="tdsql-c测评" enabled="true">
  <stringProp name="ThreadGroup.num_threads">500</stringProp>
  <stringProp name="ThreadGroup.ramp_time">20</stringProp>
  <boolProp name="ThreadGroup.scheduler">true</boolProp>
  <stringProp name="ThreadGroup.duration">600</stringProp>
</ThreadGroup>