using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading;
using System.IO;
using System.Text.RegularExpressions;
using ZennoLab.CommandCenter;
using ZennoLab.InterfacesLibrary;
using ZennoLab.InterfacesLibrary.ProjectModel;
using ZennoLab.InterfacesLibrary.ProjectModel.Collections;
using ZennoLab.InterfacesLibrary.ProjectModel.Enums;
using ZennoLab.Macros;
using Global.ZennoExtensions;
using ZennoLab.Emulation;
using MySql.Data.MySqlClient;
namespace ZennoLab.OwnCode
{
/// <summary>
/// A simple class of the common code
/// </summary>
public class CommonCode
{
/// <summary>
/// Lock this object to mark part of code for single thread execution
/// </summary>
public static object SyncObject = new object();
// Insert your code here
}
public class DB
{
private string hostname;
private string username;
private string password;
private string database;
private string charset;
private string result;
private MySqlConnection conn;
public DB(string db_hostname, string db_username, string db_password, string db_database, string db_charset="utf8"){
hostname = db_hostname;
username = db_username;
password = db_password;
database = db_database;
charset = db_charset;
result = String.Empty;
string db_port = "3306";
var m = db_hostname.Split(':');
if ( m.Length == 2 ){
db_hostname = m[0];
db_port = m[1];
}
var connectionString = "server="+db_hostname+";user="+db_username+";database="+db_database+";port="+db_port+";password="+db_password+";pooling=False;";
conn = new MySqlConnection(connectionString);
open();
}
public void open(){
conn.Open();
}
public void close(){
conn.Close();
}
public void query(string query){
MySqlCommand command = new MySqlCommand(query, conn);
command.ExecuteNonQuery();
}
public List<string> getAll(string query, string fieldSeparator="|"){
var result = new List<string>();
MySqlCommand command = new MySqlCommand(query, conn);
MySqlDataReader reader = command.ExecuteReader();
while (reader.Read())
{
List<string> fields = new List<string>();
for(int i=0; i<reader.FieldCount; i++)
fields.Add(reader[i].ToString());
result.Add(string.Join(fieldSeparator,fields));
}
reader.Close();
return result;
}
public List<string> getRow(string query){
MySqlCommand command = new MySqlCommand(query, conn);
MySqlDataReader reader = command.ExecuteReader();
if ( reader.Read() ){
List<string> result = new List<string>();
for(int i=0; i<reader.FieldCount; i++)
result.Add(reader[i].ToString());
reader.Close();
return result;
}
reader.Close();
return new List<string>();
}
public string getOne(string query){
MySqlCommand command = new MySqlCommand(query, conn);
string result = "";
try { result = command.ExecuteScalar().ToString(); } catch{}
return result;
}
public string escapeString(string text){
return MySql.Data.MySqlClient.MySqlHelper.EscapeString(text);
}
}
}
