vs2008下 连接MySQL实例

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net;
using System.Diagnostics;
using System.IO;
using System.Collections;
using MySql.Data.MySqlClient;
using System.Data;
using MySQLDriverCS;

namespace SearchBiDui
{
    class Program
    {

        static void Main(string[] args)
        {
            MySqlConnection Conn = new MySqlConnection("Database='dmoz';Data Source='localhost';User Id='root';Password='123456';charset=utf8");//连接MySQL数据库

            MySqlDataAdapter Da = new MySqlDataAdapter("select * from 4500words ", Conn);//从数据表中取出数据，没有做下次不重复的工作
            DataTable Dt = new DataTable();
            Da.Fill(Dt);

            int count = Dt.Rows.Count;  //获取记录集的长度

            for (int i = 0; i < count; i++)
            {
                int id = Convert.ToInt32(Dt.Rows[i]["id"].ToString());
                string word = Dt.Rows[i]["word"].ToString();
                string pinyin = Dt.Rows[i]["pinyin"].ToString();
                string word01 = word + "_";
                string word02 = "_" + word;

                MySqlDataAdapter Da1 = new MySqlDataAdapter("SELECT word,pinyin FROM userword2 where word like '" + word01 + "' and one = '" + pinyin + "' union all select word,pinyin from userword2 where word like '" + word02 + "' and two = '" + pinyin + "' ", Conn);               
                DataTable Dt1 = new DataTable();
                Da1.Fill(Dt1);

                int count1 = Dt1.Rows.Count;
                string speech = "";
                int pos = 0;
                for (int j  = 0; j < count1; j++)
                {
                    string word1 = Dt1.Rows[j]["word"].ToString();
                    string pinyin1 = Dt1.Rows[j]["pinyin"].ToString();
                    if (word1[0].ToString() == word)
                    {
                        pos = 1;
                    }
                    else if (word1[1].ToString() == word)
                    {
                        pos = 2;
                    }
                    else
                    {
                        pos = 0;
                        Console.WriteLine("读词有误！");
                        break;
                        break;
                    }
                    if (pos != 0)
                    {
                        speech = speech + word1 + "|" + pinyin1 + "$" + pos.ToString() + "#";
                    }
                }
                string sql = "update 4500words set speech ='" + speech + "' where id='" + id + "' ";
                RunSqlDatacmd(sql);
                if (i % 10 == 0)
                {
                    Console.WriteLine("已经执行了" + i + "条");
                }
            }
        }



        public static long RunSqlDatacmd(string sql)    //sql语句执行成员
        {
            MySqlConnection dbconn = new MySqlConnection("Database='dmoz';Data Source='localhost';User Id='root';Password='123456';charset=utf8");
            MySqlCommand cmd = dbconn.CreateCommand();
            cmd.CommandType = CommandType.Text;
            cmd.CommandText = sql;
            long ret = 0;
            try
            {
                if (cmd.Connection.State == ConnectionState.Broken)
                {
                    cmd.Connection.Close();
                    cmd.Connection.Open();
                }
                else if (cmd.Connection.State == ConnectionState.Closed)
                {
                    cmd.Connection.Open();
                }
                // else if (cmd.Connection.State == ConnectionState.Open)
                // {
                ret = cmd.ExecuteNonQuery();
                // }
                //else
                // {
                //     ret = -102;
                // }
            }
            catch (Exception ex)
            {
                string m = ex.Message;
                ret = -5;
            }
            cmd.Dispose();
            dbconn.Close();
            return ret;
        }

     }
}