Bonjour thomas,
J’ai bien reçu ton programme et je te remercie.
Effectivement en recréant mes tables sur SQLSERVEUR cela fonctionne, mais pas sur MYSQL.
J’ai donc regardé de plus près quelles étaient les différences entre SQLSERVEUR et MYSQL, et je me suis rendu compte d’une
différence majeure lors de la création de
la requête INSERT de la table Parent.
Sur SQL après l’instruction insert une instruction SELECT est rajoutée pour rafraichir le champ Id, et voilà donc pourquoi cela fonctionne
sur SQL et pas sur MYSQL.
En résumer pour ceux qui utilisent MYSQL, pour que le champ en relation se mette à jour dans la table enfant, Il faut modifier la commande INSERT de
la manière suivante :
“INSERT INTO TableParent (Col1,Col2) VALUES(@Param1,@Param2) ;SELECT
Id,Col1,Col2 FROM TableParent WHERE Id=@@IDENTITY”.
Avec une relation sur la colonne Parent.idàEnfant.id,
et une contrainte de clé étrangère qui définit la règle de mise à jour sur cascade, le champ id de la table enfant est mis à jour correctement.
Exemple complet :
DataSet
ds = new
DataSet("MonDataSet");
MySqlConnection Connection =
new MySqlConnection(connectionString);
#region TableParent (Master)
MySqlDataAdapter
daParent =
new MySqlDataAdapter();
//-->Select
sql =
"SELECT Id,Col1,Col2 FROM tableparent“;
cmd =
new MySqlCommand(sql, Connection);
daParent.SelectCommand
= cmd;
//--->Insert
sql =
"INSERT INTO tableparent (Col1,Col2) VALUES (@Col1,@Col2); SELECT Id,Col1,Col2 FROM tableparent WHERE Id=@@IDENTITY";
cmd =
new MySqlCommand(sql, Connection);
cmd.CommandType =
CommandType.Text;
cmd.Parameters.Add("@Id",
MySqlDbType.Int32, 0,
"Id");
cmd.Parameters["@Id"].Direction =
ParameterDirection.Output;
cmd.Parameters.Add("@Col1",
MySqlDbType.String, 50,
"Col1");
cmd.Parameters.Add("@Col2",
MySqlDbType.String, 50,
"Col2");
daParent.InsertCommand = cmd;
cmd.UpdatedRowSource =
UpdateRowSource.Both;
#endregion
#region TableEnfant (Child)
MySqlDataAdapter
daEnfant =
new MySqlDataAdapter();
//-->Select
sql =
"SELECT Id,IdParent,Col1,Col2 FROM tableenfant“;
cmd =
new MySqlCommand(sql, Connection);
daEnfant.SelectCommand = cmd;
//--->Insert
sql =
"INSERT INTO tableenfant (IdParent,Col1,Col2) VALUES (@IdParent,@Col1,@Col2)";
cmd =
new MySqlCommand(sql, Connection);
cmd.CommandType =
CommandType.Text;
cmd.Parameters.Add("@IdParent",
MySqlDbType.Int32, 0,
"IdParent");
cmd.Parameters.Add("@Col1",
MySqlDbType.String, 50,
"Col1");
cmd.Parameters.Add("@Col2",
MySqlDbType.String, 50,
"Col2");
daEnfant.InsertCommand = cmd;
cmd.UpdatedRowSource =
UpdateRowSource.Both;
#endregion
#region Relation (Master-->Child)
// Create Relation TableParent --> TableEnfant
DataColumn col1 = ds.Tables["TableParent"].Columns["Id"];
DataColumn col2 = ds.Tables["TableEnfant"].Columns["IdParent"];
// constraint
ForeignKeyConstraint FK =
new ForeignKeyConstraint(“FKParentEnfant”, col1, col2);
FK.DeleteRule =
Rule.Cascade;
FK.UpdateRule =
Rule.Cascade;
FK.AcceptRejectRule =
AcceptRejectRule.None;
ds.Tables[TableEnfant].Constraints.Add(FK);
ds.EnforceConstraints =
true;
// Relation
DataRelation dr =
new DataRelation("FKParentEnfant", col1, col2,
false);
ds.Relations.Add(dr);
#endregion
Connection.Open();
daParent.Fill(ds,”TableParent”);
daEnfant.Fill(ds,”TableEnfant”);
Connection.Close();
// BINDINGSOURCE
bindingSourceParent.DataSource = ds;
bindingSourceParent.DataMember =
"TableParent";
bindingSourceEnfant.DataSource = bindingSourceParent;
bindingSourceEnfant.DataMember =
"FKParentEnfant";
// Enregistrement
this.Validate();
bindingSourceParent.EndEdit();
daParent.Update(ds.Tables["TableParent"]);
bindingSourceEnfant.EndEdit();
daEnfant.Update(ds.Tables["TableEnfant"]);
Cordialement
Bertrand.
Enregistrement parent / enfant
