MySQL et .NET

Date de publication : 01/10/2004 , Date de mise a jour : 01/10/2004

Par LEBRUN Thomas (Autres Articles)
 

MySQL, la base de données la plus connue du monde Open Source, attire les développeurs par bien des égards: ses possibilités, ses performances, son prix...
SGBDR préféré des développeurs PHP, voyons comment les développeurs .NET peuvent également l'utiliser dans leurs projets (professionnels ou personnels).

1. Introduction

MySQL n'est pas supporté nativement dans l'environnement .NET. Mais, pour remédier à ce problème, vous pouvez télécharger différents providers qui vous permettront d'intégrer MySQL dans votre IDE.
Je vous recommande le provider de  MySQL Connector (anciènnement connut sous le nom ByteFx), que j'ai utilisé pour la rédaction de cet article, et que vous pourrez télécharger gratuitement à l'adresse suivante: http://dev.mysql.com/downloads/connector/net/1.0.html.

2. Installation du Provider

Mis en place du using
using ByteFX.Data.MySqlClient;

3. Les objets MySQL

4. Codage

Chaîne de connexion
string ConnnectionStr = "Database=BaseDeDonnees;Data Source=localhost;User Id=root;Password=password";

Déclaration de la connexion MySQL
private MySqlConnection Connection = new MySqlConnection();
Connection.ConnectionString = ConnnectionStr;

// Ici, on ouvre la connexion au serveur
Connection.Open();

Exécution d'une requête SELECT
private MySqlDataAdapter MyAdapter = new MySqlDataAdapter();

// On définit la requête SELECT à exécuter
string MySQLCmd = "SELECT * FROM LaTable";

// On associe cette requête à la propriété SelectCommand du MySqlDataAdapter
MyAdapter.SelectCommand = new MySqlCommand(MySQLCmd, Connection);

Remplissage du Dataset
private DataSet ds = new DataSet();

// On remplit le dataset avec le résultat de la commande SELECT
MyAdapter.Fill(ds);

Fermeture de la connexion
// On ferme la connexion le plus tôt possible
Connection.Close();

5. Code Complet

Code source complet
using System;
using System.Drawing;
using System.Collections;
using System.ComponentModel;
using System.Windows.Forms;
using System.Data;
using ByteFX.Data.MySqlClient;

namespace TestMySQL
{
	public class Form1 : System.Windows.Forms.Form
	{
		private System.Windows.Forms.TextBox tbhote;
		private System.Windows.Forms.TextBox tblogin;
		private System.Windows.Forms.Button btconnect;
		private System.Windows.Forms.TextBox tbbase;
		private System.Windows.Forms.DataGrid dataGrid1;
		private System.Windows.Forms.TextBox tbpwd;
		
		
		private System.ComponentModel.Container components = null;

		private MySqlConnection Connection = new MySqlConnection();
		private MySqlDataAdapter MyAdapter = new MySqlDataAdapter();
		private DataSet ds = new DataSet();

		public Form1()
		{
			//
			// Requis pour la prise en charge du Concepteur Windows Forms
			//
			InitializeComponent();

			//
			// TODO : ajoutez le code du constructeur après l'appel à InitializeComponent
			//
		}

		protected override void Dispose( bool disposing )
		{
			if( disposing )
			{
				if (components != null) 
				{
					components.Dispose();
				}
			}
			base.Dispose( disposing );
		}

		#region Code généré par le Concepteur Windows Form
		private void InitializeComponent()
		{
			this.tbhote = new System.Windows.Forms.TextBox();
			this.tblogin = new System.Windows.Forms.TextBox();
			this.tbpwd = new System.Windows.Forms.TextBox();
			this.btconnect = new System.Windows.Forms.Button();
			this.tbbase = new System.Windows.Forms.TextBox();
			this.dataGrid1 = new System.Windows.Forms.DataGrid();
			((System.ComponentModel.ISupportInitialize)(this.dataGrid1)).BeginInit();
			this.SuspendLayout();
			// 
			// tbhote
			// 
			this.tbhote.Location = new System.Drawing.Point(24, 16);
			this.tbhote.Name = "tbhote";
			this.tbhote.TabIndex = 0;
			this.tbhote.Text = "localhost";
			// 
			// tblogin
			// 
			this.tblogin.Location = new System.Drawing.Point(256, 16);
			this.tblogin.Name = "tblogin";
			this.tblogin.TabIndex = 1;
			this.tblogin.Text = "login";
			// 
			// tbpwd
			// 
			this.tbpwd.Location = new System.Drawing.Point(376, 16);
			this.tbpwd.Name = "tbpwd";
			this.tbpwd.PasswordChar = '*';
			this.tbpwd.TabIndex = 2;
			this.tbpwd.Text = "password";
			// 
			// btconnect
			// 
			this.btconnect.Location = new System.Drawing.Point(496, 16);
			this.btconnect.Name = "btconnect";
			this.btconnect.TabIndex = 3;
			this.btconnect.Text = "Connexion";
			this.btconnect.Click += new System.EventHandler(this.btconnect_Click);
			// 
			// tbbase
			// 
			this.tbbase.Location = new System.Drawing.Point(144, 16);
			this.tbbase.Name = "tbbase";
			this.tbbase.TabIndex = 4;
			this.tbbase.Text = "base";
			// 
			// dataGrid1
			// 
			this.dataGrid1.DataMember = "";
			this.dataGrid1.HeaderForeColor = System.Drawing.SystemColors.ControlText;
			this.dataGrid1.Location = new System.Drawing.Point(24, 64);
			this.dataGrid1.Name = "dataGrid1";
			this.dataGrid1.Size = new System.Drawing.Size(544, 184);
			this.dataGrid1.TabIndex = 5;
			// 
			// Form1
			// 
			this.AutoScaleBaseSize = new System.Drawing.Size(5, 13);
			this.ClientSize = new System.Drawing.Size(600, 266);
			this.Controls.Add(this.dataGrid1);
			this.Controls.Add(this.tbbase);
			this.Controls.Add(this.btconnect);
			this.Controls.Add(this.tbpwd);
			this.Controls.Add(this.tblogin);
			this.Controls.Add(this.tbhote);
			this.Name = "Form1";
			this.StartPosition = System.Windows.Forms.FormStartPosition.CenterScreen;
			this.Text = "MySQL et .NET";
			((System.ComponentModel.ISupportInitialize)(this.dataGrid1)).EndInit();
			this.ResumeLayout(false);

		}
		#endregion

		[STAThread]
		static void Main() 
		{
			Application.Run(new Form1());
		}

		private void btconnect_Click(object sender, System.EventArgs e)
		{
			string ConnnectionStr = String.Empty;

			if ( (tbhote.Text.Length == 0) || (tbbase.Text.Length == 0) || (tblogin.Text.Length == 0) )
			{
			 MessageBox.Show("Erreur, les champs Hôte, Base et Login doivent être remplis", "Erreur",
			 MessageBoxButtons.OK, MessageBoxIcon.Error);
			}
			else
			{
				// On définit la chaine de connexion
			 ConnnectionStr = "Database=" + tbbase.Text + ";Data Source=" + tbhote.Text + ";User Id=
			 " + tblogin.Text + ";Password=" + tbpwd.Text;
			}

			Connection.ConnectionString = ConnnectionStr;

			try
			{
				// On ouvre la connexion
				Connection.Open();

				// On définit la requête SELECT à exécuter
				string MySQLCmd = "SELECT * FROM phpbb_users";

				// On associe cette requête à la propriété SelectCommand du MySqlDataAdapter
				MyAdapter.SelectCommand = new MySqlCommand(MySQLCmd, Connection);

				// On remplit le dataset avec le résultat de la commande SELECT
				MyAdapter.Fill(ds);

				// On affiche le datagrid
				dataGrid1.DataSource = ds.Tables[0];
				dataGrid1.Refresh();

				// On ferme la connexion le plus tôt possible
				Connection.Close();
			}
			catch(MySqlException Ex)
			{
			 MessageBox.Show("Erreur SQL:\n" + Ex.Message,  "Erreur", MessageBoxButtons.OK, MessageBoxIcon.Error);
			}
		}
	}
}

6. MySQL via Internet

• Pour joindre l'hôte MySQL de votre serveur, il faut que votre hébergeur ait ouvert le port de MySQL (par défaut 3306) à l'extérieur : sur la plupart des hébergeurs, cela n'est pas fait pour des raisons de sécurité, donc à moins que vous ne possédiez votre propre serveur dédié, il vous sera impossible de réaliser votre idée
• Si vous savez que le port est ouvert mais que vous n'arrivez pas à joindre le serveur MySQL, essayer de passer par l'IP du serveur pour voir s'il ne s'agit pas d'un problème de DNS
• Joindre un site, par Internet, c'est un peu comme utiliser un WebService : cela bloque l'affichage. Pour éviter cela, penser à utiliser des Threads.

7. Conclusion

8. Téléchargement

Télécharger un exemple d'application (pour Visual Studio 2003):  Sources