先下载和安装MySQLDriverCS
http://sourceforge.net/projects/mysqldrivercs/
在安装文件夹下面找到MySQLDriver.dll,然后将MySQLDriver.dll添加引用到项目中
(增)插入数据:
using (MySQLConnection conn = new MySQLConnection(new MySQLConnectionString("localhost", "housing", "root", "root").AsString))
{
conn.Open();
//sql语句
string sql = "insert into tbl_sysuser (usercode,username,password,usertype,isActived) values(\"fc02\",\"蔡倩倩\",\"w1251314\",\"房产局管理员\",\"YES\")";
//防止乱码
MySQLCommand commn = new MySQLCommand("set names gb2312", conn);
commn.ExecuteNonQuery();
//执行sql语句
MySQLCommand cmd = new MySQLCommand(sql, conn);
//返回受影响行数
int number = cmd.ExecuteNonQuery();
//关闭数据库
conn.Close();
Console.WriteLine("受影响的行数:" + number);
}
(删)删除数据
using (MySQLConnection conn = new MySQLConnection(new MySQLConnectionString("localhost", "housing", "root", "root").AsString))
{
conn.Open();
sql语句
string sql = "delete from tbl_sysuser where usercode=\"fc02\"";
//防止乱码
MySQLCommand commn = new MySQLCommand("set names gb2312", conn);
commn.ExecuteNonQuery();
执行sql语句
MySQLCommand cmd = new MySQLCommand(sql, conn);
返回受影响行数
int number = cmd.ExecuteNonQuery();
Console.WriteLine("受影响的行数:"+number);
//关闭数据库
conn.Close();
}
(改)修改数据[注入值]
using (MySQLConnection conn = new MySQLConnection(new MySQLConnectionString("localhost", "housing", "root", "root").AsString))
{
conn.Open();
//防止乱码
MySQLCommand commn = new MySQLCommand("set names gb2312", conn);
commn.ExecuteNonQuery();
//sql语句
string sql = "update tbl_sysuser set isActived=@isActived where id=@id";
执行sql语句
MySQLCommand cmd = new MySQLCommand(sql, conn);
//注入值
cmd.Parameters.Add(new MySQLParameter("@isActived","YES"));
cmd.Parameters.Add(new MySQLParameter("@id", 1)); 返回受影响行数
int number = cmd.ExecuteNonQuery();
Console.WriteLine("受影响的行数:" + number);
//关闭数据库
conn.Close();
}
(改)修改数据
using (MySQLConnection conn = new MySQLConnection(new MySQLConnectionString("localhost", "housing", "root", "root").AsString))
{
conn.Open();
//sql语句
string sql = "update tbl_sysuser set isActived=\"YES\" where id=1";
//防止乱码
MySQLCommand commn = new MySQLCommand("set names gb2312", conn);
commn.ExecuteNonQuery();
执行sql语句
MySQLCommand cmd = new MySQLCommand(sql, conn);
返回受影响行数
int number = cmd.ExecuteNonQuery();
Console.WriteLine("受影响的行数:"+number);
//关闭数据库
conn.Close();
}
(查)查询数据:
using (MySQLConnection conn = new MySQLConnection(new MySQLConnectionString("localhost", "housing", "root", "root").AsString))
{
conn.Open();
//防止乱码
MySQLCommand commn = new MySQLCommand("set names gb2312", conn);
commn.ExecuteNonQuery();
//sql语句
string sql = "select * from tbl_sysuser";
//通过DataAdapter适配器查询
MySQLDataAdapter mda = new MySQLDataAdapter(sql, conn);
//查询出的数据是存在DataTable中的,DataTable可以理解成为一个虚拟的表,DataTable中的一行为一条记录,一列为一个数据库字段
DataTable dt = new DataTable();
mda.Fill(dt);
for (int i = 0; i < dt.Rows.Count;i++ )
{
Console.WriteLine("取出的行:"
+ dt.Rows[i]["usercode"]
+ "|" + dt.Rows[i]["username"]
+ "|" + dt.Rows[i]["password"]
+ "|" + dt.Rows[i]["usertype"]
+ "|" + dt.Rows[i]["isActived"]
);
}
//关闭数据库
conn.Close();
}
(
查)查询数据2
using (MySQLConnection conn = new MySQLConnection(new MySQLConnectionString("localhost", "housing", "root", "root").AsString))
{
conn.Open();
//防止乱码
MySQLCommand commn = new MySQLCommand("set names gb2312", conn);
commn.ExecuteNonQuery();
//sql语句
string sql = "select * from tbl_sysuser";
MySQLCommand cmd = new MySQLCommand(sql, conn);
MySQLDataReader reader = cmd.ExecuteReaderEx();
while (reader.Read())
{
if (reader.HasRows)
{
Console.WriteLine("usercode:"+reader.GetString(1)+"--username:"+reader.GetString(2));
}
}
//关闭数据库
conn.Close();
}
原文链接:https://blog.csdn.net/w605283073/article/details/43671481
本站声明:网站内容来源于网络,如有侵权,请联系我们,我们将及时处理。
还没有人抢沙发呢~