Luke.SqlProxy.Core 1.0.3

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.AddProxyRepositoryFactory<IMyRepository>();
	
    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;

    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;


    Console.Read();
}

IMyRepository

public interface IMyRepository
{

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

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

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

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

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

    [SelectEntity("select * from sys_user where name = @name;")]
    Task<SysUser> SelectUserAsync(string name);
    
    [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);

}

ProxyDbContext

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

    public DbConnection GetCurrentDbConnection()
    {
        return _connection;
    }

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

SysUser

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