|
|
|
@ -1,183 +0,0 @@ |
|
|
|
|
using System; |
|
|
|
|
using System.Collections.Generic; |
|
|
|
|
using System.Linq; |
|
|
|
|
using System.Text; |
|
|
|
|
using System.Threading.Tasks; |
|
|
|
|
using MySql.Data; |
|
|
|
|
using MySql.Data.MySqlClient; |
|
|
|
|
using Kehyeedra3.Services.Models; |
|
|
|
|
using Discord; |
|
|
|
|
using System.Timers; |
|
|
|
|
|
|
|
|
|
namespace Kehyeedra3.Services |
|
|
|
|
{ |
|
|
|
|
public class DatabaseService |
|
|
|
|
{/* |
|
|
|
|
private readonly string ConnectionString; |
|
|
|
|
private MySqlConnection Connection; |
|
|
|
|
public DatabaseService(string host, ushort port, string user, string password, string database) |
|
|
|
|
{ |
|
|
|
|
ConnectionString = $"Server={host};Port={port};Database={database};Uid={user};Pwd={password}"; |
|
|
|
|
} |
|
|
|
|
private async Task ConnectOrCreateAsync() |
|
|
|
|
{ |
|
|
|
|
if (Connection == null) |
|
|
|
|
{ |
|
|
|
|
Connection = new MySqlConnection(ConnectionString); |
|
|
|
|
} |
|
|
|
|
if (Connection.State == System.Data.ConnectionState.Open) |
|
|
|
|
return; |
|
|
|
|
else |
|
|
|
|
{ |
|
|
|
|
await Connection.OpenAsync(); |
|
|
|
|
return; |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
public async Task<bool> CreateUserAsync(IUser user) |
|
|
|
|
{ |
|
|
|
|
await ConnectOrCreateAsync(); |
|
|
|
|
|
|
|
|
|
MySqlCommand command = new MySqlCommand("INSERT INTO `users` (UserID, Avatar, UName) VALUES (@uid, @avatar, @uname);"); //userinfo |
|
|
|
|
|
|
|
|
|
command.Parameters.AddWithValue("@uid", user.Id); |
|
|
|
|
command.Parameters.AddWithValue("@avatar", user.GetAvatarUrl()); |
|
|
|
|
command.Parameters.AddWithValue("@uname", user.Username); |
|
|
|
|
|
|
|
|
|
command.Connection = Connection; |
|
|
|
|
try |
|
|
|
|
{ |
|
|
|
|
await command.ExecuteScalarAsync(); |
|
|
|
|
command.Dispose(); |
|
|
|
|
return true; |
|
|
|
|
} |
|
|
|
|
catch(Exception ex) |
|
|
|
|
{ |
|
|
|
|
Console.WriteLine(ex); |
|
|
|
|
} |
|
|
|
|
finally |
|
|
|
|
{ |
|
|
|
|
command.Dispose(); |
|
|
|
|
} |
|
|
|
|
return false; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
public async Task<bool> DoesUserExistAsync(IUser user) |
|
|
|
|
{ |
|
|
|
|
await ConnectOrCreateAsync(); |
|
|
|
|
|
|
|
|
|
var command = new MySqlCommand("SELECT 1 FROM `users` WHERE UserID = @userId;"); |
|
|
|
|
|
|
|
|
|
command.Connection = Connection; |
|
|
|
|
|
|
|
|
|
command.Parameters.AddWithValue("@userId", user.Id); |
|
|
|
|
|
|
|
|
|
return Convert.ToBoolean(await command.ExecuteScalarAsync()); |
|
|
|
|
} |
|
|
|
|
public async Task<DatabaseUser> GetUserAsync(ulong userID) |
|
|
|
|
{ |
|
|
|
|
var command = new MySqlCommand("SELECT * FROM `users` WHERE UserID = @userId;"); |
|
|
|
|
|
|
|
|
|
command.Connection = Connection; |
|
|
|
|
command.Parameters.AddWithValue("@userId", userID); |
|
|
|
|
|
|
|
|
|
var result = await command.ExecuteReaderAsync(); |
|
|
|
|
if (result.HasRows) |
|
|
|
|
{ |
|
|
|
|
while(await result.ReadAsync()) |
|
|
|
|
{ |
|
|
|
|
return new DatabaseUser //userinfo |
|
|
|
|
{ |
|
|
|
|
UserID = ulong.Parse(result["UserId"].ToString()), |
|
|
|
|
Avatar = result["Avatar"].ToString(), |
|
|
|
|
UName = result["UName"].ToString(), |
|
|
|
|
}; |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
return null; |
|
|
|
|
} |
|
|
|
|
public async Task<bool> CreateReminderAsync(ulong rUserID, string rMessage, ulong rSend) |
|
|
|
|
{ |
|
|
|
|
await ConnectOrCreateAsync(); |
|
|
|
|
|
|
|
|
|
MySqlCommand command = new MySqlCommand("INSERT INTO `reminders` (UserID, RMessage, RSend) VALUES (@uid, @rmsg, @rsend);"); //reminderinfo |
|
|
|
|
|
|
|
|
|
command.Parameters.AddWithValue("@uid", rUserID); |
|
|
|
|
command.Parameters.AddWithValue("@rmsg", rMessage); |
|
|
|
|
command.Parameters.AddWithValue("@rsend", rSend); |
|
|
|
|
command.Connection = Connection; |
|
|
|
|
try |
|
|
|
|
{ |
|
|
|
|
await command.ExecuteScalarAsync(); |
|
|
|
|
command.Dispose(); |
|
|
|
|
return true; |
|
|
|
|
} |
|
|
|
|
catch (Exception ex) |
|
|
|
|
{ |
|
|
|
|
Console.WriteLine(ex); |
|
|
|
|
} |
|
|
|
|
finally |
|
|
|
|
{ |
|
|
|
|
command.Dispose(); |
|
|
|
|
} |
|
|
|
|
return false; |
|
|
|
|
} |
|
|
|
|
public async Task<bool> DoesReminderExistAsync(IUser user) |
|
|
|
|
{ |
|
|
|
|
await ConnectOrCreateAsync(); |
|
|
|
|
|
|
|
|
|
var command = new MySqlCommand("SELECT 1 FROM `reminders` WHERE UserID = @userId;"); |
|
|
|
|
|
|
|
|
|
command.Connection = Connection; |
|
|
|
|
|
|
|
|
|
command.Parameters.AddWithValue("@userId", user.Id); |
|
|
|
|
|
|
|
|
|
return Convert.ToBoolean(await command.ExecuteScalarAsync()); |
|
|
|
|
} |
|
|
|
|
public async Task<DatabaseReminder> GetReminderAsync(ulong userID) |
|
|
|
|
{ |
|
|
|
|
var command = new MySqlCommand("SELECT * FROM `reminders` WHERE UserID = @userId;"); |
|
|
|
|
|
|
|
|
|
command.Connection = Connection; |
|
|
|
|
command.Parameters.AddWithValue("@userId", userID); |
|
|
|
|
|
|
|
|
|
var result = await command.ExecuteReaderAsync(); |
|
|
|
|
if (result.HasRows) |
|
|
|
|
{ |
|
|
|
|
while (await result.ReadAsync()) |
|
|
|
|
{ |
|
|
|
|
return new DatabaseReminder //reminderinfo |
|
|
|
|
{ |
|
|
|
|
rUserID = ulong.Parse(result["rUserID"].ToString()), |
|
|
|
|
rMessage = result["rMessage"].ToString(), |
|
|
|
|
rSend = ulong.Parse(result["rSend"].ToString()) |
|
|
|
|
}; |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
return null; |
|
|
|
|
} |
|
|
|
|
public async Task<List<DatabaseReminder>> GetAllReminderAsync() |
|
|
|
|
{ |
|
|
|
|
var command = new MySqlCommand("SELECT * FROM `reminders`;"); |
|
|
|
|
|
|
|
|
|
command.Connection = Connection; |
|
|
|
|
|
|
|
|
|
var Reminders = new List<DatabaseReminder>(); |
|
|
|
|
var result = await command.ExecuteReaderAsync(); |
|
|
|
|
if (result.HasRows) |
|
|
|
|
{ |
|
|
|
|
while (await result.ReadAsync()) |
|
|
|
|
{ |
|
|
|
|
Reminders.Add (new DatabaseReminder //reminderinfo |
|
|
|
|
{ |
|
|
|
|
rUserID = ulong.Parse(result["rUserID"].ToString()), |
|
|
|
|
rMessage = result["rMessage"].ToString(), |
|
|
|
|
rSend = ulong.Parse(result["rSend"].ToString()) |
|
|
|
|
}); |
|
|
|
|
} |
|
|
|
|
return Reminders; |
|
|
|
|
} |
|
|
|
|
return null; |
|
|
|
|
} |
|
|
|
|
*/ |
|
|
|
|
} |
|
|
|
|
} |