using System;
using System.IO;
using System.Runtime.Serialization.Formatters.Binary;
using ADODB;

namespace Server
{
    class Database
    {
        public bool AccountExist(int index,string username)
        {
            var db = Globals.mysql.DB_RS;
            {
                db.Open("SELECT * FROM accounts WHERE Username='"+username+"'", Globals.mysql.DB_CONN, ADODB.CursorTypeEnum.adOpenStatic, ADODB.LockTypeEnum.adLockOptimistic);

                if(db.EOF)
                {
                    SocketSend.SendAlertMsg(index,"Username does not exists! Please try again.");
                    db.Close();
                    return false;
                }
                else
                {
                    db.Close();
                    return true;
                }

            }
        }


        public bool PasswordOK(int index,string username,string password)
        {
            var db = Globals.mysql.DB_RS;
            {
                db.Open("SELECT Id FROM accounts WHERE Username='" + username + "' and Password='" + password + "'", Globals.mysql.DB_CONN, ADODB.CursorTypeEnum.adOpenStatic, ADODB.LockTypeEnum.adLockOptimistic);

                if (db.EOF)
                {
                    SocketSend.SendAlertMsg(index, "Password does not match! Please try again.");
                    db.Close();
                    return false;
                }
                else
                {
                    db.Close();
                    SocketSend.SendAlertMsg(index, "You have successfully logged in.");

                    return true;
                }

            }
        }

        // ADD: Create Character
        // ADD: Delete Character

        public void LoadPlayer(int index, string username)
        {
            var db = Globals.mysql.DB_RS;
            {
                db.Open("SELECT * FROM accounts WHERE Username='" + username + "'", Globals.mysql.DB_CONN, ADODB.CursorTypeEnum.adOpenStatic, ADODB.LockTypeEnum.adLockOptimistic);

                // Account
                Globals.player[index].ID = db.Fields["ID"].Value;
                Globals.player[index].Username = db.Fields["Username"].Value;

                Console.WriteLine("Username: " + Globals.player[index].Username);
                Console.WriteLine("ID: " + Globals.player[index].ID);
                //// Position
                //Globals.player[index].posX = db.Fields["X"].Value;
                //Globals.player[index].posY = db.Fields["Y"].Value;
                //Globals.player[index].posZ = db.Fields["Z"].Value;


                db.Close();  // Close Connection
            }
        }

        public void LoadAcc(int index)
        {
            var db = Globals.mysql.DB_RS;
            {
                db.Open("SELECT * FROM characters WHERE OwnerID='OwnerID'", Globals.mysql.DB_CONN, ADODB.CursorTypeEnum.adOpenStatic, ADODB.LockTypeEnum.adLockOptimistic);

                // Account
                Globals.player[index].OwnerID = db.Fields["OwnerID"].Value;


                Console.WriteLine("OwnerID:" + Globals.player[index].OwnerID);

                db.Close();  // Close Connection
            }
        }

        public void SavePlayer(int index)
        {

                var db = Globals.mysql.DB_RS;
                {
                    db.Open("SELECT * FROM accounts WHERE Username='" + Globals.player[index].Username + "'", Globals.mysql.DB_CONN, ADODB.CursorTypeEnum.adOpenStatic, ADODB.LockTypeEnum.adLockOptimistic);

                    // Position
                    db.Fields["X"].Value = Globals.player[index].posX;
                    db.Fields["Y"].Value = Globals.player[index].posY;
                    db.Fields["Z"].Value = Globals.player[index].posZ;
                    db.Update(); // Update Data
                    db.Close();  // Close Connection
                }
                //Console.WriteLine("SAVING: " + Globals.player[index].Username);

        }
    }
}