Luke.SqlProxy.Core 1.0.0

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;");

    IMyRepository productRepo = new MyRepository(connection);

    ServiceCollection serviceCollection = new ServiceCollection();

    serviceCollection.AddSingleton(productRepo);
    serviceCollection.AddProxyRepositoryFactory<IMyRepository>();
    
    IServiceProvider serviceProvider = serviceCollection.BuildServiceProvider();

    IProxyRepositoryFactory<IMyRepository> repositoryFactory = serviceProvider.GetService<IProxyRepositoryFactory<IMyRepository>>()!;

    IMyRepository proxy = repositoryFactory.CreateProxyRepository();

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

    List<SysUser> users = proxy.SelectList("Bob");
    users = proxy.SelectListAsync("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 : IProxyRepository
{

    [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);

    [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);

}

MyRepository

public class MyRepository : IMyRepository
{
    private readonly DbConnection _connection;
    public MyRepository(DbConnection connection)
    {
        _connection = connection;
    }

    public DbConnection GetCurrentDbConnection()
    {
        return _connection;
    }

    
    public DataTable SelectData(string name)
    {
        throw new NotImplementedException();
    }

    public List<SysUser> SelectList(string name)
    {
        throw new NotImplementedException();
    }

    public int InserUser(SysUser user)
    {
        throw new NotImplementedException();
    }

    public int UpdateUser(SysUser user)
    {
        throw new NotImplementedException();
    }

    public void DeleteUser(int id)
    {
        throw new NotImplementedException();
    }

    public Task<DataTable> SelectDataAsync(string name)
    {
        throw new NotImplementedException();
    }

    public Task<List<SysUser>> SelectListAsync(string name)
    {
        throw new NotImplementedException();
    }

    public Task<int> UpdateUserAsync(SysUser user)
    {
        throw new NotImplementedException();
    }

    public Task DeleteUserAsync([DbParameterName("id")] int testid)
    {
        throw new NotImplementedException();
    }
}

SysUser

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