c# - 使用 Inner Join 的 MySqlDataAdapter 更新表

Question

我正在尝试将插入、更新和删除命令添加到 MySqlDataAdapter，该适配器已使用以下命令将数据添加到它:

        //iec211.4521studenti
        string lv_sObsTable = "`" + mv_sDatabase + "`.`" + mv_sGroup + "observatii`";
        string lv_sStudTable = "`" + mv_sDatabase + "`.`" + mv_sGroup + "studenti'";
        string lv_sObservatiiCommand = "SELECT o.idObservatie, o.idStudent, s.nume, o.observatie, o.lastUpdate FROM " + lv_sObsTable + " o INNER JOIN " + lv_sStudTable + " s USING (idStudent) ORDER BY s.nume ASC";
        mv_dtAdapterObservatii = new MySqlDataAdapter(lv_sObservatiiCommand, mv_sqlConnection);
        mv_dtAdapterObservatii.Fill(mv_dsTables, lv_sCurrentTable);

我搜索了一个答案，我找到了两种可能的更新解决方案，但它们都给我一个错误:

        string lv_sObsTB = "`" + mv_sDatabase + "`.`" + mv_sGroup + "observatii`";
        string lv_sStudTB = "`" + mv_sDatabase + "`.`" + mv_sGroup + "studenti`";

        //VERSION 1
        string lv_sCommand = "UPDATE o SET s.idStudent=@idStudent, o.observatie=@observatie FROM " + lv_sObsTB + " AS o INNER JOIN " + lv_sStudTB + " s ON o.idStudent=s.idStudent ";
        MySqlCommand lv_sqlCommand = new MySqlCommand(lv_sCommand);

        lv_sqlCommand.Parameters.Add("@idStudent", MySqlDbType.Int16, 10, "idStudent");
        lv_sqlCommand.Parameters.Add("@observatie", MySqlDbType.VarChar, 255, "observatie");

        mv_dtAdapterObservatii.UpdateCommand = lv_sqlCommand;

        //VERSION 2
        string lv_sCommand = "UPDATE " + lv_sObsTB + " SET " + "idStudent=@" + lv_sStudTB + ".idStudent, observatie=@observatie WHERE idObservatie=@idObservatie AND " + lv_sObsTB + ".idStudent IN (SELECT " + lv_sStudTB + ".idStudent FROM " + lv_sStudTB + ")";
        MySqlCommand lv_sqlCommand = new MySqlCommand(lv_sCommand);

        lv_sqlCommand.Parameters.Add("@" + lv_sStudTB + ".idStudent", MySqlDbType.Int16, 10, "idStudent");
        lv_sqlCommand.Parameters.Add("@observatie", MySqlDbType.VarChar, 255, "observatie");
        lv_sqlCommand.Parameters.Add("@idObservatie", MySqlDbType.Int16, 10, "idObservatie");

        mv_dtAdapterObservatii.UpdateCommand = lv_sqlCommand;

第一个版本的错误消息是:“您的 SQL 语法有错误；请查看与您的 MySQL 服务器版本相对应的手册，了解在 'FROM iec211 附近使用的正确语法。 4521observatii ASS o INNER JOIN iec211。4521studenti s ON o.id' at line 1"

第二个版本的错误信息是:你的SQL语法有错误；查看与您的 MySQL 服务器版本对应的手册，了解在 '.4521studenti'.idStudenti, observatie='test' WHERE idObservatie=1 ANDiec211. 附近使用的正确语法' 在第 1 行"

我不知道如何将 MySQL 命令与 MySqlCommand 和 MySqlDataAdapter 结合使用。

到目前为止，我使用以下命令获取表的数据:

        string lv_sObservatiiCommand = "SELECT * FROM `" + mv_sDatabase + "`.`" + mv_sGroup + "observatii` ORDER BY idStudent ASC";
        mv_dtAdapterObservatii = new MySqlDataAdapter(lv_sObservatiiCommand, mv_sqlConnection);
        mv_dtAdapterObservatii.Fill(mv_dsTables, lv_sCurrentTable);

结合MySqlCommandBuilder获取更新命令及需要设置的参数:

        lv_sqlCommandBuilder = new MySqlCommandBuilder(mv_dtAdapterObservatii);
        mv_dtAdapterObservatii.UpdateCommand = lv_sqlCommandBuilder.GetUpdateCommand();

有人可以向我解释如何正确地将插入、更新和删除命令添加到包含 2 个表之间的 INNER JOIN 的 MySqlDataAdapter 中吗？

我知道每个表必须在不同的数据适配器中，而且它们是。 “4521studenti”表在“mv_dtAdapterStudenti”中，上面的代码中没有包含。

感谢您的帮助，我希望这不会被视为糟糕的帖子。 :)

Answer 1

好的。我想我已经弄清楚了。

这是 4521observatii 的 SELECT 命令:

        string lv_sStudent = "`" + mv_sDatabase + "`.`" + mv_sGroup + "studenti`";
        string lv_sObservatii = "`" + mv_sDatabase + "`.`" + mv_sGroup + "observatii`";
        string lv_sObservatiiCommand = "SELECT o.idObservatie, o.idStudent, s.nume, o.observatie, o.lastUpdate FROM " + lv_sObservatii + " o INNER JOIN " + lv_sStudent + " s USING (idStudent) ORDER BY s.nume ASC";
        // Read data from the server for the current table and add it to the DataSet
        mv_dtAdapterObservatii = new MySqlDataAdapter(lv_sObservatiiCommand, mv_sqlConnection);
        mv_dtAdapterObservatii.Fill(mv_dsTables, lv_sCurrentTable);

这是 UPDATE 命令的代码，在不同的方法中:

        // `iec211`.`4521observatii`
        string lv_sObsTB = "`" + mv_sDatabase + "`.`" + mv_sGroup + "observatii`";
        // `iec211`.`4521studenti`
        string lv_sStudTB = "`" + mv_sDatabase + "`.`" + mv_sGroup + "studenti`";
        string lv_sSelectStudenti = "(SELECT idStudent FROM " + lv_sStudTB + " WHERE idStudent=@idStudent)";

        string lv_sCommand = "UPDATE " + lv_sObsTB + " SET idStudent="+ lv_sSelectStudenti + ", observatie=@observatie WHERE idObservatie=@idObservatie";
        MySqlCommand lv_sqlCommand = new MySqlCommand(lv_sCommand);

        lv_sqlCommand.Parameters.Add("@idStudent", MySqlDbType.Int16, 10, "idStudent");
        lv_sqlCommand.Parameters.Add("@observatie", MySqlDbType.VarChar, 255, "observatie");
        lv_sqlCommand.Parameters.Add("@idObservatie", MySqlDbType.Int16, 10, "idObservatie");

        mv_dtAdapterObservatii.UpdateCommand = lv_sqlCommand;
        mv_dtAdapterObservatii.UpdateCommand.Connection = mv_sqlConnection;

我的想法是，当我使用 INNER JOIN 时，我从两个不同的表中获取数据并将它们放在一起。当我使用 UPDATE 命令时，程序不知道他正在使用哪个表并给出了那些错误。

所以我想如果我更新 4521observatii 的值并为用作 FOREIGN KEY 的列分配 4521studenti 的值会怎样。

我知道这就像“告诉我你的名字，这样我就可以告诉你你的名字。”，但它对我有用。

我希望这对其他人有帮助，并且您有更好更清洁的解决方案，请告诉我:)