using System;
using System.Threading;
using System.Data;
using MySql.Data.MySqlClient;
using NWN;
using System.Configuration;

namespace NWN.Scripts
{
    public class sql_async_query
    {
        static public int Main ()
        {
            //Console.WriteLine("Hello World!");
            Thread query_thread = new Thread(RunQuery);
            //query_thread.Start("INSERT INTO players (id, name) VALUES (0, 'John');");
            query_thread.Start(NWScript.GetLocalString(Object.OBJECT_SELF, "sql"));
            return 1;
        }

        static public void RunQuery(object _query)
        {
            string query = _query as string;

            string connectionString =
              "encrypt=false;" +
              "database=potm;" +
              "user=potm;" +
              "password=potmtest;" +
              "pooling=false";

            IDbConnection dbcon;
            dbcon = new MySqlConnection(connectionString);
            dbcon.Open();
            IDbCommand dbcmd = dbcon.CreateCommand();

            dbcmd.CommandText = query;

            dbcmd.ExecuteNonQuery();

            dbcmd.Dispose();
            dbcmd = null;
            dbcon.Close();
            dbcon = null;
        }
    }
}