更新/插入表

Question

我必须更新Server上的表，但首先必须检查表中的现有数据，因此如果存在数据，则更新它，如果不进行新的插入：

cmd_sql.CommandText = " SELECT BrDok as id_dok " +
                      " FROM ordersstavke " +
                      " WHERE SifParFil = '" + rw_mat["sifskl_kor"] + "'" +
                      " AND DokumentTip = '" + rw_mat["vrst_dok"] + "'";

MySqlDataAdapter sql_adapter = new MySqlDataAdapter(cmd_sql);
DataSet dt_dok = new DataSet("DOK_MAT_EXCHANGE");
sql_adapter.Fill(dt_dok);

if (dt_dok.Tables["DOK_MAT_EXCHANGE"].Rows.Count == 0)
{
   myQuery = " INSERT INTO ordersstavke (BrDok, DocumentTip, SifParFil) " +
             " VALUES ('" + rw_mat["brdok"] + "', '" +
                            rw_mat["vrst_dok"] + "', '" +
                            rw_mat["sifskl_kor"] + "')";
}
else
{
    UPDATE DATA
}

但是我在代码中有一个错误，错误在这里，如果(dt_dok.Tables["DOK_MAT_EXCHANGE"].Rows.Count == 0)

对象引用未设置为对象的实例。

问题是如果这份声明..。

Answer 1

好的，谢谢各位，我是这样写的

if (ds_dok.Tables[0].Rows.Count <= 0)
                    {
                        myQuery = " INSERT INTO ordersstavke (BrDok, " +
                                  " SifParFil) " +
                                  " VALUES ('" + rw_mat["brdok"] + "', '" +
                                                 rw_mat["sifskl_kor"] + "')";
                    }
                    else if (ds_dok.Tables[0].Rows.Count >= 1)
                    {

                        myQuery = "UPDATE ordersstavke " +
                                  "SET BrDok = '" + rw_mat["brdok"] + "', " +
                                  "SifParFil = '" + rw_mat["sifskl_kor"] + "', " +
                                  "WHERE BrDok = " + ds_dok.Tables["ordersstavke"].Rows[0]["BrDok"].ToString() + "'";

                    }

但是在更新部分中有一个小问题: s_dok.Tables"ordersstavke".Rows.ToString()，这里给出了一个可爱的错误:对象引用没有设置为对象的实例。

也许MySQL上的更新是以不同的方式进行的，我在sql server上引用的例子中，更新的方式有所不同。

Answer 2

DOK_MAT_EXCHANGE是DataSet的名称，而不是第一个表的名称。

你应该用

if (dt_dok.Tables[0].Rows.Count == 0) 

此外，我认为最好使用这样的语法来发现有多少记录是呈现的。

cmd_sql.CommandText = "SELECT COUNT(BrDok) as id_dok " +
                      " FROM ordersstavke " +                         
                      " WHERE SifParFil = ?p1 " +                         
                      " AND DokumentTip = ?p2";   
cmd_sql.Parameters.AddWithValue("?p1", rw_mat["sifskl_kor"] );
cmd_sql.Parameters.AddWithValue("?p2", rw_mat["vrst_dok"] );
int rowCount = (Int32)cmd_sql.ExecuteScalar();

Answer 3

变化

DataSet dt_dok = new DataSet("DOK_MAT_EXCHANGE");

至

DataSet dt_dok = new DataSet("ordersstavke ");

和

if (dt_dok.Tables["DOK_MAT_EXCHANGE"].Rows.Count == 0)

至

if (dt_dok.Tables["ordersstavke "].Rows.Count == 0)