lsm/SqlSugar
1
0
Fork 0
mirror of https://gitee.com/dotnetchina/SqlSugar.git synced 2025-04-05 17:37:58 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Update demo

Browse Source
This commit is contained in:
sunkaixuan 2022-09-09 21:37:42 +08:00
parent 8c7dfefb3e
commit cd7dfd036d
3 changed files with 307 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

153
Src/Asp.Net/QuestDbTest/Demo/DemoZ_Thread.cs Normal file
View File

@ -0,0 +1,153 @@
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
namespace OrmTest
{
public class DemoZ_Thread
{
public static void Init()
{
var cnt = 0;
//Separate test , Automatically build table
TestQuestDb(cnt);
// TestPgSql(cnt);
Console.ReadLine();
}
public static object lockx = new object();
private static int TestQuestDb(int cnt)
{
var questDb = GetDb();
//CreateTable
questDb.CodeFirst.InitTables<users>();
//Begin test
int errorIndex = 0;
for (var i = 0; i < 50; i++)
{
var thread = new Thread(async s =>
{
var sw = new Stopwatch();
sw.Start();
Random random = new Random();
while (sw.Elapsed < TimeSpan.FromSeconds(20))
{
var param = new { userid = random.Next(0, 10000000) };
var db = GetDb();
try
{
var result = await db.Ado.SqlQuerySingleAsync<string>("SELECT nickname from users where userid=@userid;", param);
cnt++;
Console.WriteLine($"结果:{Guid.NewGuid() + ""}");
}
catch (Exception ex)
{
Console.WriteLine($"#########################异常：{ex.Message}#############################");
errorIndex++;
}
}
sw.Stop();
Console.WriteLine($"执行次数：{cnt},错误次数{errorIndex}");
});
thread.Start(i);
}
return cnt;
}
private static int TestPgSql(int cnt)
{
var pgsql = GetPgSql();
//CreateTable
pgsql.CodeFirst.InitTables<users>();
//Begin test
int index = 1;
for (var i = 0; i < 50; i++)
{
var thread = new Thread(async s =>
{
var sw = new Stopwatch();
sw.Start();
Random random = new Random();
while (sw.Elapsed < TimeSpan.FromSeconds(10))
{
try
{
var param = new { userid = random.Next(0, 10000000) + "" };
index++;
var db = GetPgSql();
var result = await db.Ado.SqlQuerySingleAsync<string>("SELECT nickname from users where userid=@userid;", param);
Console.WriteLine($"结果:{Guid.NewGuid() + ""}");
}
catch (Exception ex)
{
Console.WriteLine($"#########################异常：{ex.Message}#############################");
}
finally
{
Interlocked.Increment(ref cnt);
}
}
sw.Stop();
Console.WriteLine($"执行次数：{cnt}");
});
thread.Start(i);
}
return cnt;
}
private static SqlSugarClient GetDb()
{
SqlSugarClient db = new SqlSugarClient(new ConnectionConfig()
{
DbType = SqlSugar.DbType.QuestDB,
ConnectionString = Config.ConnectionString,
InitKeyType = InitKeyType.Attribute,
IsAutoCloseConnection = true,
});
return db;
}
private static SqlSugarClient GetPgSql()
{
SqlSugarClient db = new SqlSugarClient(new ConnectionConfig()
{
DbType = SqlSugar.DbType.PostgreSQL,
ConnectionString = "PORT=5432;DATABASE=SqlSugar4xTest;HOST=localhost;PASSWORD=haosql;USER ID=postgres",
InitKeyType = InitKeyType.Attribute,
IsAutoCloseConnection = true,
});
return db;
}
public class users
{
public string nickname { get; set; }
public string userid { get; set; }
}
}
}

1
Src/Asp.Net/QuestDbTest/QuestDbTest.csproj
View File

@ -83,6 +83,7 @@
<Compile Include="Demo\DemoG_SimpleClient.cs" />
<Compile Include="Demo\DemoH_Snowflake.cs" />
<Compile Include="Demo\DemoJ_Report.cs" />
<Compile Include="Demo\DemoZ_Thread.cs" />
<Compile Include="Models\AttributeTable.cs" />
<Compile Include="Models\CarType.cs" />
<Compile Include="Models\Custom.cs" />

153
Src/Asp.NetCore2/QuestDbTest/Demo/DemoZ_Thread.cs Normal file
View File

@ -0,0 +1,153 @@
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
namespace OrmTest
{
public class DemoZ_Thread
{
public static void Init()
{
var cnt = 0;
//Separate test , Automatically build table
TestQuestDb(cnt);
// TestPgSql(cnt);
Console.ReadLine();
}
public static object lockx = new object();
private static int TestQuestDb(int cnt)
{
var questDb = GetDb();
//CreateTable
questDb.CodeFirst.InitTables<users>();
//Begin test
int errorIndex = 0;
for (var i = 0; i < 50; i++)
{
var thread = new Thread(async s =>
{
var sw = new Stopwatch();
sw.Start();
Random random = new Random();
while (sw.Elapsed < TimeSpan.FromSeconds(20))
{
var param = new { userid = random.Next(0, 10000000) };
var db = GetDb();
try
{
var result = await db.Ado.SqlQuerySingleAsync<string>("SELECT nickname from users where userid=@userid;", param);
cnt++;
Console.WriteLine($"结果:{Guid.NewGuid() + ""}");
}
catch (Exception ex)
{
Console.WriteLine($"#########################异常：{ex.Message}#############################");
errorIndex++;
}
}
sw.Stop();
Console.WriteLine($"执行次数：{cnt},错误次数{errorIndex}");
});
thread.Start(i);
}
return cnt;
}
private static int TestPgSql(int cnt)
{
var pgsql = GetPgSql();
//CreateTable
pgsql.CodeFirst.InitTables<users>();
//Begin test
int index = 1;
for (var i = 0; i < 50; i++)
{
var thread = new Thread(async s =>
{
var sw = new Stopwatch();
sw.Start();
Random random = new Random();
while (sw.Elapsed < TimeSpan.FromSeconds(10))
{
try
{
var param = new { userid = random.Next(0, 10000000) + "" };
index++;
var db = GetPgSql();
var result = await db.Ado.SqlQuerySingleAsync<string>("SELECT nickname from users where userid=@userid;", param);
Console.WriteLine($"结果:{Guid.NewGuid() + ""}");
}
catch (Exception ex)
{
Console.WriteLine($"#########################异常：{ex.Message}#############################");
}
finally
{
Interlocked.Increment(ref cnt);
}
}
sw.Stop();
Console.WriteLine($"执行次数：{cnt}");
});
thread.Start(i);
}
return cnt;
}
private static SqlSugarClient GetDb()
{
SqlSugarClient db = new SqlSugarClient(new ConnectionConfig()
{
DbType = SqlSugar.DbType.QuestDB,
ConnectionString = Config.ConnectionString,
InitKeyType = InitKeyType.Attribute,
IsAutoCloseConnection = true,
});
return db;
}
private static SqlSugarClient GetPgSql()
{
SqlSugarClient db = new SqlSugarClient(new ConnectionConfig()
{
DbType = SqlSugar.DbType.PostgreSQL,
ConnectionString = "PORT=5432;DATABASE=SqlSugar4xTest;HOST=localhost;PASSWORD=haosql;USER ID=postgres",
InitKeyType = InitKeyType.Attribute,
IsAutoCloseConnection = true,
});
return db;
}
public class users
{
public string nickname { get; set; }
public string userid { get; set; }
}
}
}