Beiträge von Gothic

using System;


using MySql.Data.MySqlClient;


public class MySQL
{
    public MySqlConnection mySqlConnection { get; set; }
    public MySqlCommand mySqlCommand { get; set; }
    public MySQL conn;
    public MySQL()
    {
        mySqlConnection = new MySqlConnection();
        mySqlConnection.ConnectionString = string.Format("server={0};port={1} ;user id={2}; password={3}; database={4}; pooling=false");
    }


    public void ConnectSQL()
    {
        conn = new MySQL();
        bool sqlconn = conn.TestConnect();
        if (!sqlconn)
        {
            Console.WriteLine("Verbindung Zu Datenbank Konnte nicht aufgebaut werden");
            Console.Read();
            return;
        }
        else
        {
            Console.WriteLine("Verbindung Zur Datenbank Erfolgreich aufgebaut");
           
        }


    }
    public bool TestConnect()
    {
        try
        {
            OpenConnection();
            CloseConnection();
            return true;
        }
        catch
        {
            return false;
        }
    }
    public void OpenConnection() { mySqlConnection.Open(); }
    public void CloseConnection() { mySqlConnection.Close(); }


    public MySqlCommand CreateCommand(string query)
    {
        MySqlCommand newCommand = new MySqlCommand(query, mySqlConnection);
        return newCommand;
    }


    public MySqlDataReader CreateReader(string query)
    {
        
            if (mySqlConnection.State != System.Data.ConnectionState.Open)
                OpenConnection();


            MySqlCommand mysqlCmd = new MySqlCommand(query, mySqlConnection);
            MySqlDataReader mysqlReader = mysqlCmd.ExecuteReader();
            return mysqlReader;
 
    }


    public void ExecuteQuery(string query)
    {
        MySqlCommand set = new MySqlCommand(query, mySqlConnection);


        try
        {
            if (mySqlConnection.State != System.Data.ConnectionState.Open)
                OpenConnection();


            set.ExecuteNonQuery();
        }
        catch (Exception excp)
        {
            Console.WriteLine(excp.Message);
            Console.WriteLine(query);
        }
        CloseConnection();
    }
    public void runSQL(string Syntax)
    {
        try
        {
            conn.OpenConnection();
            MySqlCommand SqlCmd = new MySqlCommand(Syntax, conn.mySqlConnection);
            SqlCmd.ExecuteNonQuery();
            Console.WriteLine(Syntax);
            conn.CloseConnection();
        }
        catch (MySqlException ex)
        {
            Console.WriteLine(ex.ToString());
            Console.WriteLine("Fehler mit Query : " + Syntax + "");


        }
    }


  
}