在 C# 中使用 MySQL 命令动态创建表

Question

我想动态创建表并用随机数填充，但是在执行代码时，MySQL 会抛出语法错误。

 for (int i = 0; i < 100; i++)
        {
            //gameSession is int, i tried use Parameters.AddWithValue but still have same problem.
            MySqlCommand dice = new MySqlCommand("INSERT INTO "+gameSession.ToString()+" (Dice1,Dice2) Values (@dice1,@dice2)", myConnection);


            Random dice1 = new Random();
            dice.Parameters.AddWithValue("@dice1", dice1.Next(1, 7));
            Random dice2 = new Random();
            dice.Parameters.AddWithValue("@dice2", dice2.Next(1, 7));
            if (myConnection.State == ConnectionState.Closed)
            {
                myConnection.Open();
            }
            dice.ExecuteNonQuery();
        }

您的 SQL 语法有错误；检查与您的 MySQL 服务器版本相对应的手册，了解在 INSERT INTO '7571877 附近使用的正确语法 ...

Answer 1

语法错误的一个主要原因是该表没有被引用。查看MySQL manual for identifiers（包括表名）。

就像默认情况下您不能真正使用数字来表示变量一样，如果不转义标识符，您也不能对表执行相同的操作。一些解决方案是在表名前加上一个字母或使用单个表。

回答标题中的问题：

如果它不存在，您可以使用“IF NOT EXISTS”子句create a table。 SQL 如下所示：

CREATE TABLE table_name IF NOT EXISTS (
    dice1 INTEGER,
    dice2 INTEGER
);

如果你坚持走这条路，你应该用标准的前缀字母创建你的表名：

"s" + gameSession.ToString()

请注意，为每个会话设置一个单独的表确实会使您的数据库维护需求变得复杂，尤其是在处理废弃会话时。删除单个表中的行比查找所有废弃的表要容易得多。

另一个严重的问题与数据库安全有关。在针对数据库构建应用程序时，只授予用户插入和更新权限比授予他们在数据库中创建和删除任何表的能力要好得多。由于表名是动态创建的，因此您不能真正轻松地维护每个表的权限。如果这是面向网络的，那么您将承担一些严重的责任，而收益却很少。

满足需求：

更好的设计是创建一个带有会话 ID 的表。否则，您将拥有任意数量的表，每个表都有一条记录。您将像这样创建表一次：

CREATE TABLE DiceRolls IF NOT EXISTS (
    session INTEGER,
    dice1 INTEGER,
    dice2 INTEGER
);

您的插入内容只需要稍作改动：

 for (int i = 0; i < 100; i++)
    {
        //gameSession is int, i tried use Parameters.AddWithValue but still have same problem.
        MySqlCommand dice = new MySqlCommand("INSERT INTO DiceRolls (Session, Dice1,Dice2) Values (@session,@dice1,@dice2)", myConnection);

        dice.Parameters.AddWithValue("@session", gameSession);
        Random dice1 = new Random();
        dice.Parameters.AddWithValue("@dice1", dice1.Next(1, 7));
        Random dice2 = new Random();
        dice.Parameters.AddWithValue("@dice2", dice2.Next(1, 7));
        if (myConnection.State == ConnectionState.Closed)
        {
            myConnection.Open();
        }
        dice.ExecuteNonQuery();
    }

这使得清理工作变得更加容易，因为您可以批处理作业，删除所有不是当前会话的内容。

Answer 2

问题在于您的表名。确保表名正确，然后使用此函数：

void InsertDiece(string connectionString, string tableName, int count)
{
    var commandText = String.Format("INSERT INTO `{0}` (Dice1, Dice2) Values (@dice1, @dice2)", tableName);
    var random = new Random(DateTime.Now.Milliseconds);
    using(var connection = new MySqlConnection(connectionString))
    using(var command = connection.CreateCommand())
    {
        connection.Open();
        command.CommandText = commandText;
        for(int i = 0; i < count; i++)
        {
            command.Parameters.AddWithValue("@dice1", random.Next(1, 7));
            command.Parameters.AddWithValue("@dice2", random.Next(1, 7));
            command.ExecuteNonQuery();
            command.Parameters.Clear();
        }
    }
}