using System; using System.Collections.Generic; using System.Data; using System.Linq; using System.Text; using MySql.Data.MySqlClient; using TShockAPI.Extensions; namespace TShockAPI.DB { public interface IQueryBuilder { string CreateTable(SqlTable table); string AlterTable(SqlTable from, SqlTable to); string DbTypeToString(MySqlDbType type, int? length); } public class SqliteQueryCreator : IQueryBuilder { public string CreateTable(SqlTable table) { var columns = table.Columns.Select(c => "'{0}' {1} {2} {3} {4}".SFormat(c.Name, DbTypeToString(c.Type, c.Length), c.Primary ? "PRIMARY KEY" : "", c.AutoIncrement ? "AUTOINCREMENT" : "", c.NotNull ? "NOT NULL" : "", c.Unique ? "UNIQUE" : "")); return "CREATE TABLE '{0}' ({1})".SFormat(table.Name, string.Join(", ", columns)); } static Random rand = new Random(); /// /// Alter a table from source to destination /// /// Must have name and column names. Column types are not required /// Must have column names and column types. /// public string AlterTable(SqlTable from, SqlTable to) { var rstr = rand.NextString(20); var alter = "ALTER TABLE '{0}' RENAME TO '{1}_{0}'".SFormat(from.Name, rstr); var create = CreateTable(to); //combine all columns in the 'from' variable excluding ones that aren't in the 'to' variable. //exclude the ones that aren't in 'to' variable because if the column is deleted, why try to import the data? var insert = "INSERT INTO '{0}' ({1}) SELECT {1} FROM {2}_{0}".SFormat(from.Name, string.Join(", ", from.Columns.Where(c => to.Columns.Any(c2 => c2.Name == c.Name)).Select(c => c.Name)), rstr); var drop = "DROP TABLE '{0}_{1}'".SFormat(rstr, from.Name); return "{0}; {1}; {2}; {3};".SFormat(alter, create, insert, drop); /* ALTER TABLE "main"."Bans" RENAME TO "oXHFcGcd04oXHFcGcd04_Bans" CREATE TABLE "main"."Bans" ("IP" TEXT PRIMARY KEY ,"Name" TEXT) INSERT INTO "main"."Bans" SELECT "IP","Name" FROM "main"."oXHFcGcd04oXHFcGcd04_Bans" DROP TABLE "main"."oXHFcGcd04oXHFcGcd04_Bans" */ } static readonly Dictionary TypesAsStrings = new Dictionary { {MySqlDbType.VarChar, "TEXT"}, {MySqlDbType.String, "TEXT"}, {MySqlDbType.Text, "TEXT"}, {MySqlDbType.TinyText, "TEXT"}, {MySqlDbType.MediumText, "TEXT"}, {MySqlDbType.LongText, "TEXT"}, {MySqlDbType.Int32, "INTEGER"}, }; public string DbTypeToString(MySqlDbType type, int? length) { string ret; if (TypesAsStrings.TryGetValue(type, out ret)) return ret; throw new NotImplementedException(Enum.GetName(typeof(MySqlDbType), type)); } } public class MysqlQueryCreator : IQueryBuilder { public string CreateTable(SqlTable table) { var columns = table.Columns.Select(c => "{0} {1} {2} {3}".SFormat(c.Name, DbTypeToString(c.Type, c.Length), c.Primary ? "PRIMARY KEY" : "", c.AutoIncrement ? "AUTOINCREMENT" : "", c.NotNull ? "NOT NULL" : "")); var uniques = table.Columns.Where(c => c.Unique).Select(c => c.Name); return "CREATE TABLE {0} ({1}) {2}".SFormat(table.Name, string.Join(", ", columns), uniques.Count() > 0 ? ", UNIQUE({0})".SFormat(string.Join(", ", uniques)) : ""); } static Random rand = new Random(); /// /// Alter a table from source to destination /// /// Must have name and column names. Column types are not required /// Must have column names and column types. /// public string AlterTable(SqlTable from, SqlTable to) { var rstr = rand.NextString(20); var alter = "RENAME TABLE {0} TO {1}_{0}".SFormat(from.Name, rstr); var create = CreateTable(to); //combine all columns in the 'from' variable excluding ones that aren't in the 'to' variable. //exclude the ones that aren't in 'to' variable because if the column is deleted, why try to import the data? var insert = "INSERT INTO {0} ({1}) SELECT {1} FROM {2}_{0}".SFormat(from.Name, string.Join(", ", from.Columns.Where(c => to.Columns.Any(c2 => c2.Name == c.Name)).Select(c => c.Name)), rstr); var drop = "DROP TABLE {0}_{1}".SFormat(rstr, from.Name); return "{0}; {1}; {2}; {3};".SFormat(alter, create, insert, drop); } static readonly Dictionary TypesAsStrings = new Dictionary { {MySqlDbType.VarChar, "VARCHAR"}, {MySqlDbType.String, "CHAR"}, {MySqlDbType.Text, "TEXT"}, {MySqlDbType.TinyText, "TINYTEXT"}, {MySqlDbType.MediumText, "MEDIUMTEXT"}, {MySqlDbType.LongText, "LONGTEXT"}, {MySqlDbType.Int32, "INT"}, }; public string DbTypeToString(MySqlDbType type, int? length) { string ret; if (TypesAsStrings.TryGetValue(type, out ret)) return ret + (length != null ? "({0})".SFormat((int)length) : ""); throw new NotImplementedException(Enum.GetName(typeof(MySqlDbType), type)); } } }