Sample.DBUtility.Core 1.0.7

Sample.DBUtility.Core

DBUtility Example

// 1. 專案中建立目錄夾 "SqlCommands"

// 2. 新增 SqlCommands\xxx.sql
SELECT email FROM member WHERE email = '{0}'

// 3. 開啟 .csproj 加入
<ItemGroup>
    <Content Include="SqlCommands\**\*" CopyToOutputDirectory="Always" />
</ItemGroup>

// 4. 設定連線字串 
"MyDemoDBConnection": "server=;user id=;password=;port=;database=;Max Pool Size=100;Min Pool Size=5"

// 5. snippet code
public class someclass{
    private static readonly NLog.Logger _logger = NLog.LogManager.GetCurrentClassLogger();
    private static readonly MySQLUtility _dbUtil = MySQLUtility.instance;
    private static readonly Utility _utility = Utility.instance;
    private readonly string _connString = "";
    
    public someclass(MySQLUtility db){
        _connString = _utility.GetConfigField("MyDemoDBConnection");
    }

    public async Task demo()
    {
        
        try
        {
            string strSQL = "read_xxx.sql_full_text";
            string[] conditions = {"demo@email.com"};
            List<DBModel> lstxxx = await _db.GetDataFromMySQL<DBModel>(_connString,conditions, strSQL);
        }
        catch (Exception e)
        {
            _logger.Trace(e.StackTrace);
            _logger.Error(e.Message);
        }
    }
}

MongoUtility Example

// 1. 設定連線字串 
"MongoDBConnectionString": "mongodb://id:password@domain:port/db?authSource=admin&retryWrites=true&w=majority"

// 2. snippet code
public class someclass{
    private static readonly NLog.Logger _logger = NLog.LogManager.GetCurrentClassLogger();
    private static readonly MongoUtility _mongoUtil = MongoUtility.instance;
    private static readonly Utility _utility = Utility.instance;
    private readonly string _connString = "";
    
    public someclass(){
        _connString = _utility.GetConfigField("MongoDBConnectionString");
    }

    public void demo()
    {
        try
        {   
            // Query
            FilterDefinition<DBModel> filter = Builders<DBModel>.Filter.Regex(o => o.field, new BsonRegularExpression($"/search value/"));
            List<DBModel> respRecords = await _mongoUtil.GetDataFromMongo(_connString, "Database", "Collection", filter, 0, 50);
            // Insert
            _mongoClient.InsertMongo<DBModel>(_connString."Database", "Collection", respRecords);
        }
        catch (Exception e)
        {
            _log.Trace(e.StackTrace);
            _log.Error(e.Message);
        }
    }
}

ElasticsearchUtility Example

// 1. 設定連線字串 
"ElasticSearchConnection":{
    "node":"http://domain:port",
    "authorization":"Base64.Encode(id:password)"
}


// 3. snippet code
public class someclass{
    private static readonly NLog.Logger _logger = NLog.LogManager.GetCurrentClassLogger();
    private static readonly ElasticsearchUtility _esUtil = ElasticsearchUtility.instance;
    private static readonly Utility _utility = Utility.instance;
    private readonly Dictionary<string, object> _dictEsConn;
    
    public someclass(ElasticsearchUtility esClient){
        _dictEsConn = _utility.GetConfigSection("ElasticSearchConnection");
        _esUtil.SetupConnection(_dictEsConn["node"].ToString(), _dictEsConn["authorization"].ToString());
    }

    public void demo()
    {
        try
        {
            // Insert
            bool isSuccess = await _esUtil.InsertES("index", new List<DBModel>());
            // Query
            List<DBModel> resp = await _esUtil.SimpleQueryES<DBModel>("index", q => q.Match(m => m.Field(f => f.field_name).Query("search value")));
        }
        catch (Exception e)
        {
            _log.Trace(e.StackTrace);
            _log.Error(e.Message);
        }
    }
}