一、C# 对数据库的操作步骤

1、引入命名空间

 Using System.Data.SqlClient     

2、设置连接字符串

string sql = “ server = . ; database = Data0216 ; user=sa ; pwd =   ";

//sql 设的字符串名
//server 指服务器:一般是IP地址,本机可以使用点;
//database 指数据库名称:要访问的数据库名称           
//user 数据库的用户名:一般是sa           
//pwd 数据库的密码:自己设置的

3、建立数据库连接对象

SqlConnection conn = new  SqlConnection(sql);

//SqlConnection 连接对象类

4、创建命令对象

SqlCommand cmd = conn.CreateCommand();

//SqlCommand 命令对象类

5、给命令对象写要执行的SQL语句

//查询
cmd.CommandText = "select * from Info";
//添加
cmd.CommandText = "Insert into Info values('p032','张三','True','n001','1987-02-02')";
//删除
cmd.CommandText = "delete from Info where Code='p032';
// 更改
cmd.CommandText = "update Info set name='李四' where Code='p032'; //CommandText 命令文本

6、打开连接

 conn.Open(); 

7、执行操作,处理数据

(1)查询操作

SqlDataReader  dr  =  cmd.ExecuteReader();  //dr 代表返回的是一个结果集 SqlDataReader 读取器对象类
if (dr.HasRows)                 //HasRows 判断是否有行数据 bool型,返回true/false  
{     
while(dr.Read())            // dr.Read() 数据库数据访问指针,每执行一次向下走一行,有内容则返回true,没有返回 false
{                    // dr访问为当前行数据集合,可以使用索引或是列名来访问相对应的数据
string ids = dr[].ToString();
string username = dr[].ToString();
string birthday = dr["Birthday"].ToString();
string password = dr["PassWord"].ToString();
                       //使用while循环读取所有数据,当dr.Read(); 返回值是 false 时跳出循环
}
}   
else   
{     
Console.WriteLine("读取失败!");   
}

(2)增、删、改操作

int   a  =  cmd.ExecuteNonQuery();   //a 返回的是 int 类型,表示几行受影响
if ( a > )
{     
Console.WriteLine("成功");   
}
else   
{     
Console.WriteLine("读失败!");   
}

8、关闭连接 

conn.Close();

注意事项:

每次打开数据库只能执行,增、删、改、查。中的一个

注意在有循环运行的时候,尽量避免有频繁的开关数据库,可将开关放到循环外

使用  break; 跳出循环时,注意跳出后的位置与 conn.Close(); 的关系 。容易出现不经过conn.Close();,没有关上库。

二、对数据库操作的实例

  1、查询一个表的所有数据

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Data.SqlClient; namespace ConsoleApplication2
{
class Program
{
static void Main(string[] args)
{
//连接字符串
string sql = "server=.;database=Data0216;user=sa;pwd=123"; //创建据库连接
SqlConnection conn = new SqlConnection(sql); //创建命令对象
SqlCommand cmd = conn.CreateCommand(); //执行的SQL语句
cmd.CommandText = "select *from Users"; 打开连接
conn.Open(); //执行操作,数据处理
SqlDataReader dr = cmd.ExecuteReader(); if (dr.HasRows)
{
while (dr.Read())
{
string ids = dr[].ToString();
string username = dr[].ToString();
string birthday = dr["Birthday"].ToString();
string password = dr["PassWord"].ToString();
string nickname = dr["NickName"].ToString();
string sex = dr["Sex"].ToString();
string nation = dr["Nation"].ToString(); Console.WriteLine(ids + " | " + username + " | " + password + " | " + nickname + " | " + sex + " | " + birthday + " | " + nation);
}
} //关闭连接
conn.Close(); Console.ReadKey();
}
}
}

2、删除数据

using System;
using System.Collections.Generic;
using System.Data.SqlClient;
using System.Linq;
using System.Text; namespace ConsoleApplication1
{
class Program
{
static void Main(string[] args)
{
string sql = "server=.;database=Data0216;user=sa;pwd=123"; SqlConnection conn = new SqlConnection(sql); SqlCommand cmd = conn.CreateCommand(); cmd.CommandText = "delete from users where username='zhangsan'"; conn.Open(); int a = cmd.ExecuteNonQuery(); if (a > )
{
Console.WriteLine("删除成功,本次共删除" + a + "行");
} else
{
Console.WriteLine("删除失败,本次未删除任何数据");
} conn.Close(); Console.ReadLine();
}
}
}

 3、修改数据

using System;
using System.Collections.Generic;
using System.Data.SqlClient;
using System.Linq;
using System.Text; namespace ConsoleApplication3
{
class Program
{
static void Main(string[] args)
{
bool has = false; string sql = "server=.;database=Data0216;user=sa;pwd=123"; SqlConnection conn = new SqlConnection(sql); SqlCommand cmd = conn.CreateCommand(); Console.Write("请输入要修改的用户的用户名:");
string name = Console.ReadLine(); cmd.CommandText = "select *from Users where UserName = '" + name + "'"; conn.Open(); SqlDataReader dr = cmd.ExecuteReader(); if (dr.HasRows)
{
has = true;
}
conn.Close(); if (!has)
Console.WriteLine("用户名输入错误!查无此用户");
else
{
Console.WriteLine("已查询到此用户,请输入更改的信息");
Console.Write("请输入修改后的密码:");
string password = Console.ReadLine();
Console.Write("请输入修改后的昵称:");
string nickname = Console.ReadLine();
Console.Write("请输入修改后的性别:");
string sex = Console.ReadLine();
Console.Write("请输入修改后的生日:");
string birthday = Console.ReadLine();
Console.Write("请输入修改后的民族:");
string nation = Console.ReadLine(); cmd.CommandText = "update Users set PassWord='" + password + "',NickName='" + nickname + "',Sex='" + sex + "',Birthday='" + birthday + "',Nation='" + nation + "' where UserName = '" + name + "'"; conn.Open(); int aaa = cmd.ExecuteNonQuery(); conn.Close(); if (aaa > )
{
Console.WriteLine("修改成功");
}
else
{
Console.WriteLine("修改失败");
}
} Console.ReadLine(); }
}
}

 4、有条件的添加数据

using System;
using System.Collections.Generic;
using System.Data.SqlClient;
using System.Linq;
using System.Text; namespace ConsoleApplication3
{
class Program
{
static void Main(string[] args)
{ //编写一个完整的,带限制的添加功能 string sql = "server=.;database=Data0216_5;user=sa;pwd=123"; SqlConnection conn = new SqlConnection(sql); SqlCommand cmd = conn.CreateCommand(); #region 添加该用户名 string name; while (true)
{
Console.Write("请输入用户名");
name = Console.ReadLine();
//不能为空,不能重复 if (name.Length == )
{
Console.WriteLine("输入错误!用户名不能为空");
}
else
{
cmd.CommandText = " select Username from users where Username='" + name + "'"; conn.Open(); SqlDataReader dr = cmd.ExecuteReader(); if (dr.HasRows)
{
Console.WriteLine("输入错误!该用户已存在");
}
else
{
break;
} } } conn.Close();
#endregion #region 添加密码 string password;
while (true)
{
Console.Write("请输入密码(6位以上数字字母):");
password = Console.ReadLine();
//不能小于6位 if (password.Length < )
{
Console.WriteLine("输入有误!密码不能小于6位数");
}
else
{
break;
}
} #endregion #region 添加昵称 string nickname;
while (true)
{
Console.Write("请输入昵称:");
nickname = Console.ReadLine();
//不能为空 if (nickname.Length == )
{
Console.WriteLine("昵称不能为空");
}
else
{
break;
} }
#endregion #region 添加性别 string sex;
while (true)
{
Console.Write("请输入性别(男/女):");
sex = Console.ReadLine();
//让用户输入 男 女 if (sex == "男")
{
sex = "true";
break;
}
else if (sex == "女")
{
sex = "false ";
break;
}
else {
Console.WriteLine("输入有误!性别只有<男/女>");
}
}
#endregion #region 添加生日 string birthday;
while (true)
{
Console.Write("请输入生日:");
birthday = Console.ReadLine();
//日期格式是否正确
try
{
DateTime dt = new DateTime();
dt = Convert.ToDateTime(birthday);
break;
}
catch
{
Console.WriteLine("日期格式不正确");
}
} #endregion #region 添加名族 string nation; while (true)
{
Console.Write("请输入民族:");
nation = Console.ReadLine();
//有无此民族 cmd.CommandText = "select NationCode from usernation where NationName like '" + nation + "%'; "; conn.Open(); SqlDataReader der = cmd.ExecuteReader();
if (der.HasRows)
{
der.Read();
nation = der["NationCode"].ToString();
break;
}
else
{
Console.WriteLine("暂无此民族");
} }
conn.Close(); #endregion #region 执行添加程序 cmd.CommandText = "insert into users values('" + name + "','" + password + "','" + nickname + "','" + sex + "','" + birthday + "','" + nation + "')";
conn.Open(); int a = cmd.ExecuteNonQuery();
if (a > )
{
Console.WriteLine("添加成功!");
}
else
{
Console.WriteLine("添加失败!!");
} conn.Close(); #endregion Console.ReadLine(); }
}
}
05-11 19:47