c# 连接Mysql数据库
2014-08-10 11:45
204 查看
摘要: c# 连接Mysql数据库
using System.Data;
using MySql.Data.MySqlClient;
private MySqlConnection conn;
private DataTable data;
private MySqlDataAdapter da;
private MySqlCommandBuilder cb;
private DataGrid dataGrid;
private void connectBtn_Click(object sender, System.EventArgs e)
{
if (conn != null)
conn.Close();
string connStr = String.Format("server={0};user id={1}; password={2}; port={3}; database=mysql; pooling=false; charset=utf8",
server.Text, userid.Text, password.Text, 3306);
try
{
conn = new MySqlConnection( connStr );
conn.Open();
GetDatabases();
MessageBox.Show("连接数据库成功!");
}
catch (MySqlException ex)
{
MessageBox.Show( "Error connecting to the server: " + ex.Message );
}
}
private void GetDatabases()
{
MySqlDataReader reader = null;
MySqlCommand cmd = new MySqlCommand("SHOW DATABASES", conn);
try
{
reader = cmd.ExecuteReader();
databaseList.Items.Clear();
while (reader.Read())
{
databaseList.Items.Add( reader.GetString(0) );
}
}
catch (MySqlException ex)
{
MessageBox.Show("Failed to populate database list: " + ex.Message );
}
finally
{
if (reader != null) reader.Close();
}
}
private void databaseList_SelectedIndexChanged(object sender, System.EventArgs e)
{
MySqlDataReader reader = null;
conn.ChangeDatabase(databaseList.SelectedItem.ToString());
MySqlCommand cmd = new MySqlCommand("SHOW TABLES", conn);
try
{
reader = cmd.ExecuteReader();
tables.Items.Clear();
while (reader.Read())
{
tables.Items.Add( reader.GetString(0) );
}
}
catch (MySqlException ex)
{
MessageBox.Show("Failed to populate table list: " + ex.Message );
}
finally
{
if (reader != null) reader.Close();
}
}
private void tables_SelectedIndexChanged(object sender, System.EventArgs e)
{
data = new DataTable();
da = new MySqlDataAdapter("SELECT * FROM " + tables.SelectedItem.ToString(), conn );
cb = new MySqlCommandBuilder( da ); // 此处必须有,否则无法更新
da.Fill( data );
dataGrid.DataSource = data;
}
private void updateBtn_Click(object sender, System.EventArgs e)
{
DataTable changes = data.GetChanges();
da.Update( changes );
data.AcceptChanges();
}
using System.Data;
using MySql.Data.MySqlClient;
private MySqlConnection conn;
private DataTable data;
private MySqlDataAdapter da;
private MySqlCommandBuilder cb;
private DataGrid dataGrid;
private void connectBtn_Click(object sender, System.EventArgs e)
{
if (conn != null)
conn.Close();
string connStr = String.Format("server={0};user id={1}; password={2}; port={3}; database=mysql; pooling=false; charset=utf8",
server.Text, userid.Text, password.Text, 3306);
try
{
conn = new MySqlConnection( connStr );
conn.Open();
GetDatabases();
MessageBox.Show("连接数据库成功!");
}
catch (MySqlException ex)
{
MessageBox.Show( "Error connecting to the server: " + ex.Message );
}
}
private void GetDatabases()
{
MySqlDataReader reader = null;
MySqlCommand cmd = new MySqlCommand("SHOW DATABASES", conn);
try
{
reader = cmd.ExecuteReader();
databaseList.Items.Clear();
while (reader.Read())
{
databaseList.Items.Add( reader.GetString(0) );
}
}
catch (MySqlException ex)
{
MessageBox.Show("Failed to populate database list: " + ex.Message );
}
finally
{
if (reader != null) reader.Close();
}
}
private void databaseList_SelectedIndexChanged(object sender, System.EventArgs e)
{
MySqlDataReader reader = null;
conn.ChangeDatabase(databaseList.SelectedItem.ToString());
MySqlCommand cmd = new MySqlCommand("SHOW TABLES", conn);
try
{
reader = cmd.ExecuteReader();
tables.Items.Clear();
while (reader.Read())
{
tables.Items.Add( reader.GetString(0) );
}
}
catch (MySqlException ex)
{
MessageBox.Show("Failed to populate table list: " + ex.Message );
}
finally
{
if (reader != null) reader.Close();
}
}
private void tables_SelectedIndexChanged(object sender, System.EventArgs e)
{
data = new DataTable();
da = new MySqlDataAdapter("SELECT * FROM " + tables.SelectedItem.ToString(), conn );
cb = new MySqlCommandBuilder( da ); // 此处必须有,否则无法更新
da.Fill( data );
dataGrid.DataSource = data;
}
private void updateBtn_Click(object sender, System.EventArgs e)
{
DataTable changes = data.GetChanges();
da.Update( changes );
data.AcceptChanges();
}
相关文章推荐
- c#连接MySql数据库的两种方法
- c#连接MySql数据库的两种方法
- C#连接MySql数据库方法
- C# 连接MYSQL数据库的方法及示例
- c#连接MySql数据库的两种方法
- C#连接到MySql数据库
- C#连接MySQL数据库,实现CRUD
- c# asp.net MySql.Data.DLL6.2下载,.net连接mysql数据库的第三方插件
- C#连接mysql数据库
- c#连接MySql数据库的两种方法
- c#连接MySql数据库的两种方法
- C#连接MySql数据库的方法
- 使用mysql.data.mysqlclient实现C#连接MySQL数据库
- c# 连接MySql数据库的两种方法
- c#连接MySql数据库的两种方法
- c#连接MySql数据库的两种方法
- vs2008下c#连接MySQL数据库
- C#连接MySql数据库的方法
- c#远程连接mysql数据库
- 使用mysql.data.mysqlclient实现C#连接MySQL数据库