Luke.SqlProxy.Core 1.0.6

Luke.SqlProxy

A Simple Proxy-Repository

How to use？

Program

static void Main(string[] args)
{
    DbConnection connection = new MySqlConnection("Database=dev_test;Data Source=127.0.0.1;User Id=root;Password=123456;CharSet=utf8mb4;port=3306;Old Guids=true;");

    ServiceCollection serviceCollection = new ServiceCollection();

    serviceCollection.AddTransient<IProxyDbContext>((sp) => new ProxyDbContext(connection));

    serviceCollection.AddProxyRepositoryConfig(conf => { conf.AutoJoinTransaction = true; });
    serviceCollection.AddTransientProxyRepository<IMyRepository>();

    IServiceProvider serviceProvider = serviceCollection.BuildServiceProvider();

    IMyRepository proxy = serviceProvider.GetService<IMyRepository>();

    DataTable dt = proxy.SelectData("Bob");
    dt = proxy.SelectDataAsync("Bob").Result;

    List<SysUser> users = proxy.SelectList("Bob");
    users = proxy.SelectListAsync("Bob").Result;

    SysUser user = proxy.SelectUser("Bob");

    user = proxy.SelectUserAsync("Bob").Result;

    List<int> ids = proxy.SelectId("Bob");

    string name = proxy.SelectName(1);

    proxy.DeleteUserAsync(2).Wait();

    int count = proxy.InserUser(new SysUser { id = 2, name = "test" });

    count = proxy.UpdateUser(new SysUser { id = 2, name = "test1" });
    count = proxy.UpdateUserAsync(new SysUser { id = 2, name = "test2" }).Result;


    int id = proxy.InserIdentityUser(new SysUser { name = "test" + DateTime.Now.ToString("yyMMddHHmmss") });

    Console.Read();
}

IMyRepository

public interface IMyRepository
{

    [Select("select * from sys_user where name = @name;")]
    DataTable SelectData(string name);

    [Select("select * from sys_user where name = @name;")]
    Task<DataTable> SelectDataAsync(string name);

    [Select("select * from sys_user where name = @name;")]
    List<SysUser> SelectList(string name);

    [Select("select * from sys_user where name = @name;")]
    Task<List<SysUser>> SelectListAsync(string name);

    [Select("select * from sys_user where name = @name;")]
    SysUser SelectUser(string name);

    [Select("select * from sys_user where name = @name;")]
    Task<SysUser> SelectUserAsync(string name);

    [Select("select * from sys_user where name = @name;")]
    List<int> SelectId(string name);

    [Select("select id from sys_user where name = @name;")]
    Task<List<int>> SelectIdAsync(string name);

    [Select("select name from sys_user where id = @id;")]
    string SelectName(int id);

    [Select("select name from sys_user where id = @id;")]
    Task<string> SelectNameAsync(int id);

    [Insert("insert into sys_user(id, name) values (@id, @name);")]
    int InserUser(SysUser user);

    [Update("update sys_user set name = @name where id = @id;")]
    int UpdateUser(SysUser user);

    [Update("update sys_user set name = @name where id = @id;")]
    Task<int> UpdateUserAsync(SysUser user);

    [Delete("delete from sys_user where id = @id;")]
    void DeleteUser([DbParameterName("id")]int testid);

    [Delete("delete from sys_user where id = @id;")]
    Task DeleteUserAsync([DbParameterName("id")] int testid);

    [Insert("insert into sys_user(name) values (@name);select @@identity;", selectIdentity: true)]
    int InserIdentityUser(SysUser user);

}

ProxyDbContext

public class ProxyDbContext : IProxyDbContext, IDisposable
{
    private readonly DbConnection _connection;
    public ProxyDbContext(DbConnection connection)
    {
        _connection = connection;
    }

    public DbConnection GetCurrentDbConnection()
    {
        return _connection;
    }

    private DbTransaction? _transaction = null;

    public DbTransaction? GetCurrentDbTransaction()
    {
        return _transaction;
    }

    public void BeginTransaction()
    {
        if (_transaction == null)
        {
            _transaction = _connection.BeginTransaction();
        }
    }


    public void Dispose()
    {
        _connection.Dispose();
    }

    
}

SysUser

public class SysUser
{
    public int id { get; set; }
    public string name { get; set; }
}

Return Type Maps