AAEmu.Commons/Utils/DB/MySQL.cs - develop - NLObP/AAEmu

AAEmu.Commons/Utils/DB/MySQL.cs

64 строки2 KB

Roger Barreto

Adding Dictionary, Cleaning all warnings (#1109)

10 дек 2024, 19:51

10 дек 2024, 19:517605fdd

using System;
using AAEmu.Commons.Models;
using MySql.Data.MySqlClient;
using NLog;

#pragma warning disable IDE0079 // Remove unnecessary suppression

namespace AAEmu.Commons.Utils.DB;

public static class MySQL
{
    private static Logger Logger { get; } = LogManager.GetCurrentClassLogger();
    private static string s_connectionString;

    static MySQL()
    {
        SetConfiguration(null);
    }

    public static MySqlConnection CreateConnection()
    {
#pragma warning disable CA2000 // Dispose objects before losing scope
        var connection = new MySqlConnection(s_connectionString);
#pragma warning restore CA2000 // Dispose objects before losing scope
        try
        {
            connection.Open();
        }
        catch (Exception e)
        {
            Logger.Fatal($"Error on DB connect: {e.Message}");
            return null;
        }

        return connection;
    }

    public static void Close(MySqlConnection connection)
    {
        connection.Close();
    }

    public static void SetConfiguration(MySqlConnectionSettings mySqlConnectionSettings)
    {
        var builder = new MySqlConnectionStringBuilder()
        {
            Server = mySqlConnectionSettings?.Host ?? "localhost",
            Port = mySqlConnectionSettings?.Port ?? 3306,
            UserID = mySqlConnectionSettings?.User ?? "root",
            Password = mySqlConnectionSettings?.Password ?? "",
            Database = mySqlConnectionSettings?.Database ?? "",
            Pooling = true,
            MinimumPoolSize = 0,
            MaximumPoolSize = 10,
            ConnectionLifeTime = 600,
            CharacterSet = "utf8",
            AllowZeroDateTime = true,
            ConvertZeroDateTime = true,
            DefaultCommandTimeout = 180,
            SslMode = MySqlSslMode.Prefered
        };
        s_connectionString = builder.ConnectionString;
    }
}