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

namespace 連接數(shù)據(jù)庫
{
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(“連接失��！”);
}
}
}

/執(zhí)行增刪改操作/
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using MySql.Data;
using System.Data;
using MySql.Data.MySqlClient;

namespace 連接數(shù)據(jù)庫
{
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 連接數(shù)據(jù)庫
{
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"]);
        }

    }
}

}

/連續(xù)查詢/
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using MySql.Data;
using System.Data;
using MySql.Data.MySqlClient;

namespace 連接數(shù)據(jù)庫
{
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");//連接數(shù)據(jù)庫
        SqlDataAdapter sda = new SqlDataAdapter("select * from tb_emp",conn);
        DataSet ds = new DataSet();
        sda.Fill(ds);
        dataGridView1.DataSource = ds.Tables[0];//綁定數(shù)據(jù)源到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)//連接數(shù)據(jù)庫，填充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())                       //調(diào)用private Bool dbUpdate()并判斷

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

        }
        try
        {
            this.conn.Open();                            //打開數(shù)據(jù)庫并更新
            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();//更新數(shù)據(jù)庫
        return true;
    }
}

標簽： Mysql 數(shù)據(jù)庫

版權申明：本站文章部分自網(wǎng)絡，如有侵權，請聯(lián)系：west999com@outlook.com
特別注意：本站所有轉載文章言論不代表本站觀點！
本站所提供的圖片等素材，版權歸原作者所有，如需使用，請與原作者聯(lián)系。