新手C#SQLServer在程序里实现语句的学习2018.08.12

时间:2022-06-16 16:31:51

从C#中连接到SQL Server数据库,再通过C#编程实现SQL数据库的增删改查。

ado.net提供了丰富的数据库操作,这些操作可以分为三个步骤:

  • 第一,使用SqlConnection对象连接数据库;
  • 第二,建立SqlCommand对象,负责SQL语句的执行和存储过程的调用;(在使用适配器查找记录时不用建立sqlcommand对象)
  • 第三,对SQL或存储过程执行后返回的“结果”进行操作。对结果的操作分为两种,一种为SqlDataReader一行一行读取数据集,另一种为DataSet联合SqlDataAdapter读取数据集。

1.打开连接通道:

        #region 打开连接通道
/// <summary>
///1.连接通道的连接字符串
///2.连接通道对象
///3.打开通道
///4.关闭通道
/// </summary>
public static void OpenConnection()
{
//1.连接通道的连接字符串
string conStr = "server=192.168.1.100;database=JNU;uid=sa;pwd=123456aa;";//指定哪台服务器
//2.连接通道对象
SqlConnection conn = new SqlConnection(conStr);
//3.打开通道
conn.Open();
//4.关闭通道
conn.Close();
Console.WriteLine("连接对象新建操作成功");
}
#endregion

2.增加记录

        #region 增加记录
/// <summary>
/// 增加记录
/// </summary>
public static void AddRecord()
{
int res = -;//准备比接受新增受影响的行数
string conStr = "server=192.168.1.100;database=JNU;uid=sa;pwd=123456aa;";
//1.新建连接通道
SqlConnection conn = new SqlConnection();
//2.手动指定连接字符串
conn.ConnectionString = conStr;
//3.准备新增的sql命令
string sqlStr = "insert into TEST(NAME) values('SHUAI')";
//4.新建命令对象,并且告诉他走那条路(conn),做什么事('sqlStr')单引号一定要加
SqlCommand cmd = new SqlCommand(sqlStr, conn);
//5.打开连接通道
conn.Open();
//6.调用方法去数据库执行sql语句
res = cmd.ExecuteNonQuery();//此方法负责增删改,返回受影响的行数(int),开始进入数据库进行操作
//7.关闭连接通道
conn.Close();
if (res > )
{
Console.WriteLine("新增成功");
}
else
{
Console.WriteLine("新增失败");
}
}
#endregion

3.删除记录和更改记录(软删除)与新增记录的代码相同,只有SQL语句不一样,其SQL语句为

            //3.准备删除的sql命令
string sqlStr = "delete from TEST where ID=8";
//3.准备修改的sql命令
string sqlStr = "update TEST set NAME='qiang' where ID=7";

4.查询单个值时,使用的是命令对象SqlCommand进行查询

        #region 查询单个值
/// <summary>
/// 查询单个值
/// </summary>
public static void QuerySingle()
{
SqlConnection conn = new SqlConnection(conStr);
// string sqlStr = "select count(*) from TEST";
string sqlStr = "select * from TEST";
SqlCommand cmd = new SqlCommand(sqlStr, conn);
conn.Open();
//调用此方法,获得查询语句在数据库执行后得到的结果集的第一个单元格的值,返回类型为object
object obj = cmd.ExecuteScalar();
conn.Close();
Console.WriteLine(obj.ToString()); }
#endregion

5.读取器查询多行数据,逐行读取,通过下标访问数据,还可以通过列名和get方法访问数据

        #region 读取器查询多行数据,逐行读取,通过get方法访问数据
/// <summary>
/// 查询多行数据——DataReader,逐行读取
/// </summary>
public static void QueryListByGet()
{
SqlConnection conn = new SqlConnection(conStr);
string sqlStr = "select * from TEST";
SqlCommand cmd = new SqlCommand(sqlStr, conn);
conn.Open();
//调用此方法,获得一个读取器对象,SqlDataReader不能实例化
SqlDataReader dr = cmd.ExecuteReader();
//if (dr.HasRows)//判断有无数据
//{
// Console.WriteLine("有数据");
//}
//else
//{
// Console.WriteLine("无数据");
//}
if (dr.HasRows)
{
//每调用一次read,读取一行数据
while (dr.Read())//read方法,如果读到下一行数据,则返回true,而且dr本身就等于哪一行数据
{
//读取第一列的数据
//Console.WriteLine(dr[0].ToString());//通过下标访问数据,数组下标从0开始
//Console.WriteLine(dr["ID"].ToString());//通过列名访问数据,以结果集的列名作为标志,可以避免as为别名后的查询错误
Console.WriteLine(dr.GetString());//通过get访问数据,数组下标从0开始,只能用于char类型的变量,不能获取int类型的数据
Console.WriteLine(dr.GetInt32());//只能获取int类型
Console.WriteLine(dr.GetValue().ToString());//以object的方式拿出数据
dr.GetOrdinal("ID");//传入列名,获得列的下标 }
}
else
Console.WriteLine("无数据");
//先关闭读取器,再关闭连接通道
dr.Close();
conn.Close();
}
#endregion

6.适配器查询多行数据

        #region 适配器查询多行数据
/// <summary>
/// 使用适配器读取数据,不需要代码手动打开、关闭连接通道
/// </summary>
public static void QueryListByAdapter()
{
SqlConnection conn = new SqlConnection(conStr);
string sqlStr = "select * from TEST";
//创建适配器对象(SqlDataAdapter),告诉他做什么事(sqlStr),走哪条路(conn)
SqlDataAdapter sqlda = new SqlDataAdapter(sqlStr, conn);
//创建数据集对象(程序端的临时数据库)
DataSet ds = new DataSet();
//调用fill方法,添加数据到数据集。(先去数据库查询结果集,并把结果集返回赋值给数据集)
sqlda.Fill(ds);//开始进入数据库进行操作
DataTable dt = ds.Tables[];//获得数据集中的第一张表(数据集可以存放多张表)
for (int i = ; i < dt.Rows.Count; i++)//循环该表中的每一行,dt.Rows为获取该数据表的行集合
{
DataRow dr = dt.Rows[i];//dr对象获取表中的当前行
Console.WriteLine(dr[].ToString());//通过索引的方式读某一列的值
Console.WriteLine(dr["ID".ToString()]);//通过列名的方式读列
}
}
#endregion

2018.08.12