Advertisement
Guest User

MySQO Database.cs

a guest
May 20th, 2017
94
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
C# 3.37 KB | None | 0 0
  1. using Discord;
  2. using MySql.Data.MySqlClient;
  3. using System;
  4. using System.Collections.Generic;
  5. using System.Linq;
  6.  
  7. namespace MyBot
  8. {
  9.     class Database
  10.     {
  11.         private string table { get; set; }
  12.         private const string server = "localhost";
  13.         private const string database = "fly_bot_discord";
  14.         private const string username = "root";
  15.         private const string password = "jaron2003";
  16.         private MySqlConnection dbConnection;
  17.  
  18.         public Database(string table)
  19.         {
  20.             this.table = table;
  21.             MySqlConnectionStringBuilder stringBuilder = new MySqlConnectionStringBuilder();
  22.             stringBuilder.Server = server;
  23.             stringBuilder.UserID = username;
  24.             stringBuilder.Password = password;
  25.             stringBuilder.Database = database;
  26.             stringBuilder.SslMode = MySqlSslMode.None;
  27.  
  28.             var connectionString = stringBuilder.ToString();
  29.  
  30.             dbConnection = new MySqlConnection(connectionString);
  31.  
  32.             dbConnection.Open();
  33.         }
  34.  
  35.         public MySqlDataReader FireCommand(string query)
  36.         {
  37.             if (dbConnection == null)
  38.             {
  39.                 return null;
  40.             }
  41.  
  42.             MySqlCommand command = new MySqlCommand(query, dbConnection);
  43.  
  44.             var mySqlReader = command.ExecuteReader();
  45.  
  46.             return mySqlReader;
  47.         }
  48.  
  49.         public void CloseConnection()
  50.         {
  51.             if(dbConnection != null)
  52.             {
  53.                 dbConnection.Close();
  54.             }
  55.         }
  56.  
  57.         public static List<String> CheckExistingUser(IUser user)
  58.         {
  59.             var result = new List<String>();
  60.             var database = new Database("fly_bot_discord");
  61.  
  62.             var str = string.Format("SELECT * FROM fly_bot WHERE user_id = {0}", user.Id);
  63.             var fly_bot_table = database.FireCommand(str);
  64.  
  65.             while (fly_bot_table.Read())
  66.             {
  67.                 var userId = (string)fly_bot_table["user_id"];
  68.  
  69.                 result.Add(userId);
  70.             }
  71.  
  72.             return result;
  73.         }
  74.  
  75.     public static string EnterUser(IUser user)
  76.         {
  77.             var database = new Database("fly_bot_discord");
  78.  
  79.             var str = string.Format("INSERT INTO fly_bot (user_id, username, tokens ) VALUES ({0}, {1}, 100)", user.Id, user.Username);
  80.             var table = database.FireCommand(str);
  81.  
  82.             database.CloseConnection();
  83.  
  84.             return null;
  85.         }
  86.  
  87.     public static List<fly_bot_table> GetUserStatus(IUser user)
  88.         {
  89.             var result = new List<fly_bot_table>();
  90.  
  91.             var database = new Database("fly_bot_discord");
  92.  
  93.             var str = string.Format("SELECT * FROM fly_bot WHERE user_id = {0}", user.Id);
  94.             var tableName = database.FireCommand(str);
  95.  
  96.             while (tableName.Read())
  97.             {
  98.                 var userId = (string)tableName["user_id"];
  99.                 var userName = (string)tableName["username"];
  100.                 var currentTokens = (uint)tableName["tokens"];
  101.  
  102.                 result.Add(new fly_bot_table
  103.                 {
  104.                     userid = userId,
  105.                     username = userName,
  106.                     tokens = currentTokens
  107.                 });
  108.             }
  109.             database.CloseConnection();
  110.  
  111.             return result;
  112.  
  113.         }
  114.     }
  115. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement