C#連接數據庫操作

vs2010中運行，必須引用Mysql.data
/連接數據庫/
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using MySql.Data;
using System.Data;
using MySql.Data.MySqlClient;

namespace 連接數據庫
{
class Program
{
static void Main(string[] args)
{
MySqlConnection conn = null;
conn=new MySqlConnection(“Data Source=localhost;Database=php;User ID=root;Password=111111”);
conn.Open();
if (conn.State.ToString() == “Open”)
Console.WriteLine(“連接成功！”);
else
Console.WriteLine(“連接失敗！”);
}
}
}
/執行增刪改操作/
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using MySql.Data;
using System.Data;
using MySql.Data.MySqlClient;
namespace 連接數據庫
{
class Program
{
static void Main(string[] args)
{
MySqlConnection conn = null;
conn=new MySqlConnection(“Data Source=localhost;Database=php;User ID=root;Password=111111”);
conn.Open();
if (conn.State.ToString() == “Open”)
Console.WriteLine(“連接成功！”);
else
Console.WriteLine(“連接失敗！”);

    MySqlCommand com = new MySqlCommand();
    com.Connection = conn;
    com.CommandText = "insert into class values(1,'xiaoming',23),(2,'xiaoliang',5)";
    int i = com.ExecuteNonQuery();
    if (i > 0)
        Console.WriteLine("插入記錄{0}條", i);
    else
        Console.WriteLine("插入不成功！");
}

}
}
/查詢操作/
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using MySql.Data;
using System.Data;
using MySql.Data.MySqlClient;
namespace 連接數據庫
{
class Program
{
static void Main(string[] args)
{
MySqlConnection conn = null;
conn=new MySqlConnection(“Data Source=localhost;Database=php;User ID=root;Password=111111”);
conn.Open();
if (conn.State.ToString() == “Open”)
Console.WriteLine(“連接成功！”);
else
Console.WriteLine(“連接失敗！”);

    MySqlCommand com = new MySqlCommand("select * from class", conn);
    MySqlDataReader dr = null;
    dr = com.ExecuteReader();
    while (dr.Read())
    {
        Console.WriteLine(dr["id"] + " " + dr["name"] + " " + dr["age"]);
    }

}

}
}
/連續查詢/
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using MySql.Data;
using System.Data;
using MySql.Data.MySqlClient;
namespace 連接數據庫
{
class Program
{
static void Main(string[] args)
{
MySqlConnection conn = null;
conn=new MySqlConnection(“Data Source=localhost;Database=php;User ID=root;Password=111111”);
conn.Open();
if (conn.State.ToString() == “Open”)
Console.WriteLine(“連接成功！”);
else
Console.WriteLine(“連接失敗！”);

    MySqlCommand com = new MySqlCommand("select * from class where id =1;select * from class where id =2", conn);
    MySqlDataReader dr = null;
    dr = com.ExecuteReader();
    while (dr.Read())
    {
        Console.WriteLine(dr["id"] + " " + dr["name"] + " " + dr["age"]);
    }
    if (dr.NextResult())
    {
        while(dr.Read())
            Console.WriteLine(dr["id"] + " " + dr["name"] + " " + dr["age"]);
    }

}

}
}
SqlConnection conn;
    SqlDataAdapter adapter;
    private void button1_Click(object sender, EventArgs e)
    {
        conn = new SqlConnection("server=.;database=db_16;uid=sa;pwd=123456");//連接數據庫
        SqlDataAdapter sda = new SqlDataAdapter("select * from tb_emp",conn);
        DataSet ds = new DataSet();
        sda.Fill(ds);
        dataGridView1.DataSource = ds.Tables[0];//綁定數據源到datagridView
        dataGridView1.RowHeadersVisible = false;//隱藏首列
        for (int i = 0; i < dataGridView1.ColumnCount;i++ )
        {
            dataGridView1.Columns[i].Width = 84;
        }
        button1.Enabled = false;
        dataGridView1.Columns[0].ReadOnly = true;
    }
    private DataTable dbconn(string strSql)//連接數據庫，填充DataTable并返回

  {
        conn.Open();
        this.adapter = new SqlDataAdapter(strSql, conn);
        DataTable dtSelect = new DataTable();
        int rnt = this.adapter.Fill(dtSelect);
        conn.Close();
        return dtSelect;
    }
    private void button2_Click(object sender, EventArgs e)
    {
        if (dbUpdate())                       //調用private Bool dbUpdate()并判斷

    {
        MessageBox.Show("修改成功！");
    }
}
private Boolean dbUpdate()
{
    string strSql = "select * from tb_emp";
    DataTable dtUpdate = new DataTable();
    dtUpdate = this.dbconn(strSql);//調用private DataTable dbconn(string strSql)并得到dtUpdate空表
    dtUpdate.Rows.Clear();
    DataTable dtShow = new DataTable();
    dtShow = (DataTable)this.dataGridView1.DataSource;//把修改后的datagridview數據綁定到dtShow表中
    for (int i = 0; i < dtShow.Rows.Count; i++)
    {
        dtUpdate.ImportRow(dtShow.Rows[i]);//把dtShow表中的數據復制到dtUpdate空表中

    }
    try
    {
        this.conn.Open();                            //打開數據庫并更新
        SqlCommandBuilder CommandBuiler;
        CommandBuiler = new SqlCommandBuilder(this.adapter);
        this.adapter.Update(dtUpdate);
        this.conn.Close();
    }
    catch (Exception ex)
    {
        MessageBox.Show(ex.Message.ToString());
        return false;
    }
    dtUpdate.AcceptChanges();//更新數據庫
    return true;
}

}
</pre>