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;
}

}
}