DataKit/DataKit.SQL.MySQL/MySQLDataProvider.cs at master · DevJohnC/DataKit

68 lines (58 loc) · 1.78 KB

﻿using DataKit.SQL.Providers;
using MySql.Data.MySqlClient;
using System.Threading;
using System.Threading.Tasks;

namespace DataKit.SQL.MySQL
{
	public class MySQLDataProvider : DataProviderBase
	{
		public const string PROVIDER_NAME = "MySQL/MariaDB";

		public static MySQLDataProvider Create(string host, string user, string pass, string database)
		{
			return new MySQLDataProvider(new MySqlConnectionStringBuilder
			{
				Server = host,
				UserID = user,
				Password = pass,
				Database = database
			});
		}

		public static MySQLDataProvider CreateWithoutSSL(string host, string user, string pass, string database)
		{
			return new MySQLDataProvider(new MySqlConnectionStringBuilder
			{
				Server = host,
				UserID = user,
				Password = pass,
				Database = database,
				SslMode = MySqlSslMode.None
			});
		}

		public override string ProviderName => PROVIDER_NAME;

		private readonly string _connectionString;

		public MySQLDataProvider(string connectionString)
		{
			_connectionString = connectionString;
		}

		public MySQLDataProvider(MySqlConnectionStringBuilder connectionStringBuilder) :
			this(connectionStringBuilder.ConnectionString)
		{
		}

		protected override QueryWriter CreateQueryWriter()
		{
			return new MySQLQueryWriter();
		}

		protected override IConnectionLease OpenConnection()
		{
			var connection = new MySqlConnection(_connectionString);
			connection.Open();
			return new ClosingConnectionLease(connection);
		}

		protected override async Task<IConnectionLease> OpenConnectionAsync(CancellationToken cancellationToken)
		{
			var connection = new MySqlConnection(_connectionString);
			await connection.OpenAsync(cancellationToken);
			return new ClosingConnectionLease(connection);
		}
	}
}

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Expand file tree

Search code, repositories, users, issues, pull requests...

FilesExpand file tree

MySQLDataProvider.cs

Latest commit

History

MySQLDataProvider.cs

File metadata and controls

Expand file tree