C#+MYSQL数据库操作（附源码）

看到了一篇很好的日志http://blog.sina.com.cn/s/blog_43eb83b90100mb08.html

在这个日志的启发下，我做出了自己的一个简单的系统，数据库录入，数据库查询~我的代码附在这里C#+MYSQL

另外，把我写的一些SQL代码也贴出来吧：

 

drop table test1.testtable1;create table test1.testtable1(a char(10) not null,b char(18) not null,primary key (a),unique(a),key(b));

delete from test1.testtable1;insert into test1.testtable1(a,b) values ("00000001","11111111111111111X");insert into test1.testtable1(a,b) values ("00000002","00000000000000000X");insert into test1.testtable1(a,b) values ("00000003","22222222222222222X");

select b from test1.testtable1 where a="00000001";#找到了对应a的那个b.select * from test1.testtable1;#这句话可以显示所有

show  columns from  test1.testtable1;#这个会显示列show tables from test1;show index from test1.testtable1;#显示table里面的indexshow table status from test1;#就会返回这个表的状态show variables like 'b%';#查找像的变量show status;

其实慢慢看mysql的中文参考是蛮有好处的，特别是第七章和第八章。也一起上传到这里。

下面是那篇我看过参考过的日志的内容：

using System;using System.Configuration;using MySql.Data.MySqlClient;/// <summary>/// TestDatebase 的摘要说明/// </summary>public class TestDatebase{    public TestDatebase()    {        //        // TODO: 在此处添加构造函数逻辑        //    }    public static void Main(String[] args)    {        MySqlConnection mysql = getMySqlCon();        //查询sql        String sqlSearch = "select * from student";        //插入sql        String sqlInsert = "insert into student values (12,'张三',25,'大专')";        //修改sql        String sqlUpdate = "update student set name='李四' where id= 3";        //删除sql        String sqlDel = "delete from student where id = 12";        //打印SQL语句        Console.WriteLine(sqlDel);        //四种语句对象        //MySqlCommand mySqlCommand = getSqlCommand(sqlSearch, mysql);        //MySqlCommand mySqlCommand = getSqlCommand(sqlInsert, mysql);        //MySqlCommand mySqlCommand = getSqlCommand(sqlUpdate, mysql);        MySqlCommand mySqlCommand = getSqlCommand(sqlDel, mysql);        mysql.Open();        //getResultset(mySqlCommand);        //getInsert(mySqlCommand);        //getUpdate(mySqlCommand);        getDel(mySqlCommand);        //记得关闭        mysql.Close();       String readLine = Console.ReadLine();    }    /// <summary>    /// 建立mysql数据库链接    /// </summary>    /// <returns></returns>    public static MySqlConnection getMySqlCon()    {        String mysqlStr = "Database=test;Data Source=127.0.0.1;User Id=root;Password=root;pooling=false;CharSet=utf8;port=3306";        // String mySqlCon = ConfigurationManager.ConnectionStrings["MySqlCon"].ConnectionString;        MySqlConnection mysql = new MySqlConnection(mysqlStr);        return mysql;    }    /// <summary>    /// 建立执行命令语句对象    /// </summary>    /// <param name="sql"></param>    /// <param name="mysql"></param>    /// <returns></returns>    public static MySqlCommand getSqlCommand(String sql,MySqlConnection mysql)    {        MySqlCommand mySqlCommand = new MySqlCommand(sql, mysql);        //  MySqlCommand mySqlCommand = new MySqlCommand(sql);        // mySqlCommand.Connection = mysql;        return mySqlCommand;    }    /// <summary>    /// 查询并获得结果集并遍历    /// </summary>    /// <param name="mySqlCommand"></param>    public static void getResultset(MySqlCommand mySqlCommand)    {        MySqlDataReader reader = mySqlCommand.ExecuteReader();        try        {            while (reader.Read())            {                if (reader.HasRows)                {                    Console.WriteLine("编号:" + reader.GetInt32(0) + "|姓名:" + reader.GetString(1) + "|年龄:" + reader.GetInt32(2) + "|学历:" + reader.GetString(3));                }            }        }        catch (Exception)        {            Console.WriteLine("查询失败了！");        }        finally        {            reader.Close();        }    }    /// <summary>    /// 添加数据    /// </summary>    /// <param name="mySqlCommand"></param>    public static void getInsert(MySqlCommand mySqlCommand)    {        try        {            mySqlCommand.ExecuteNonQuery();        }        catch (Exception ex)        {            String message = ex.Message;            Console.WriteLine("插入数据失败了！" + message);        }          }    /// <summary>    /// 修改数据    /// </summary>    /// <param name="mySqlCommand"></param>    public static void getUpdate(MySqlCommand mySqlCommand)    {        try        {            mySqlCommand.ExecuteNonQuery();        }        catch (Exception ex)        {            String message = ex.Message;            Console.WriteLine("修改数据失败了！" + message);        }    }    /// <summary>    /// 删除数据    /// </summary>    /// <param name="mySqlCommand"></param>    public static void getDel(MySqlCommand mySqlCommand)    {        try        {            mySqlCommand.ExecuteNonQuery();        }        catch (Exception ex)        {            String message = ex.Message;            Console.WriteLine("删除数据失败了！" + message);        }    }}

转载于:https://www.cnblogs.com/liuliunumberone/archive/2012/03/14/2396735.html

相关资源：C# MySQL数据库操作类库 含源码