using System;
using System.Collections.Generic;
using System.Text;
class SQLCon
{
private static MySql.Data.MySqlClient.MySqlConnection[] con = new MySql.Data.MySqlClient.MySqlConnection[10];
private static MySql.Data.MySqlClient.MySqlConnection sabitCon = null;
private static int current = -1;
private static **** conAl() {
current = (current + 1) % 10;
try
{
con[current].Close();
}
catch { }
con[current] = new MySql.Data.MySqlClient.MySqlConnection("SERVER=<sunucu adresin>;DATABASE=<veritabanı>;UID=<kullanıcı adı>;PASSWORD=<şifre>;charset=utf8;");
con[current].Open();
new MySql.Data.MySqlClient.MySqlCommand("set names 'utf8' collate 'utf8_turkish_ci'", con[current]).ExecuteNonQuery();
new MySql.Data.MySqlClient.MySqlCommand("SET CHARACTER SET utf8", con[current]).ExecuteNonQuery();
new MySql.Data.MySqlClient.MySqlCommand("SET COLLATION_CONNECTION = 'utf8_turkish_ci'", con[current]).ExecuteNonQuery();
}
private static **** sabitConAl()
{
if (sabitCon == null)
{
sabitCon = new MySql.Data.MySqlClient.MySqlConnection("SERVER=<sunucu adresin>;DATABASE=<veritabanı>;UID=<kullanıcı adı>;PASSWORD=<şifre>;charset=utf8;");
sabitCon.Open();
new MySql.Data.MySqlClient.MySqlCommand("set names 'utf8' collate 'utf8_turkish_ci'", sabitCon).ExecuteNonQuery();
new MySql.Data.MySqlClient.MySqlCommand("SET CHARACTER SET utf8", sabitCon).ExecuteNonQuery();
new MySql.Data.MySqlClient.MySqlCommand("SET COLLATION_CONNECTION = 'utf8_turkish_ci'", sabitCon).ExecuteNonQuery();
}
}
private static MySql.Data.MySqlClient.MySqlCommand komutVer(string sql, params object[] objeler)
{
conAl();
MySql.Data.MySqlClient.MySqlCommand comm = new MySql.Data.MySqlClient.MySqlCommand(sql, con[current]);
for (int i = 0; i < objeler.Length; i++) comm.Parameters.Add("@prm" + i, objeler[i]);
return comm;
}
private static MySql.Data.MySqlClient.MySqlCommand sabitKomutVer(string sql, params object[] objeler)
{
sabitConAl();
MySql.Data.MySqlClient.MySqlCommand comm = new MySql.Data.MySqlClient.MySqlCommand(sql, sabitCon);
for (int i = 0; i < objeler.Length; i++) comm.Parameters.Add("@prm" + i, objeler[i]);
return comm;
}
internal static int sonucsuz(string sql, params object[] objeler)
{
return sabitKomutVer(sql, objeler).ExecuteNonQuery();
}
internal static int identity(string sql, params object[] objeler)
{
return int.Parse(scalar(sql + ";select @@identity;", objeler).ToString());
}
internal static object scalar(string sql, params object[] objeler)
{
return sabitKomutVer(sql, objeler).ExecuteScalar();
}
internal static MySql.Data.MySqlClient.MySqlDataReader reader(string sql, params object[] objeler)
{
return komutVer(sql, objeler).ExecuteReader();
}
public static System.Data.DataTable dataSource(string sql, params object[] objeler)
{
System.Data.DataSet dataSet = new System.Data.DataSet();
new MySql.Data.MySqlClient.MySqlDataAdapter(komutVer(sql, objeler)).Fill(dataSet);
return dataSet.Tables[0];
}
}