C# 连接SQL server 增删改查

青旅半醒 2022-05-25 07:15 213阅读 0赞

using System;
    using System.Collections.Generic;
    using System.Data.SqlClient;
    using System.Linq;
    using System.Text;
    using System.Threading.Tasks;
     
    namespace _03.ado.net
    {
        class Program
        {
            static void Main(string[] args)
            {
                #region 连接数据库
                连接数据库的步骤：
                1.创建连接字符串
                Data Source=服务器名;
                Initial Catalog=数据库名;
                Integrated Security=True;声明验证方式
                用户名、密码方式
                //string constr = "Data Source=localhost;Initial Catalog=zwt;uid=root;pwd=zwt";
                集成式
                string constr = "Data Source=localhost;Initial Catalog=zwt;integrated Security=true";
     
                2.创建连接对象
                //using (SqlConnection con = new SqlConnection(constr))
                //{
                //    //测试，打开连接
                //    //3.打开连接（如果打开数据连接没有问题，表示连接成功）
                //    con.Open();
                //    Console.WriteLine("数据库连接成功");
                //    //4.关闭连接，释放资源
                //    con.Close();
     
                //    //con.Dispose();
                //}
                //Console.WriteLine("断开连接");
                //Console.ReadKey();
                #endregion
     
                #region 增加数据
                连接数据库的步骤：
                1.创建连接字符串
                Data Source=服务器名;
                Initial Catalog=数据库名;
                Integrated Security=True;声明验证方式
                用户名、密码方式
                //string constr = "Data Source=localhost;Initial Catalog=zwt;uid=root;pwd=zwt";
                集成式
                string constr = "Data Source=localhost;Initial Catalog=zwt;integrated Security=true";
     
                2.创建连接对象
                //using (SqlConnection con = new SqlConnection(constr))
                //{
                //    //4.编写SQL语句
                //    string sql = "insert into zwt values('Tony',23,'男')";
                //    //5.创建一个执行sql语句的对象（命令对象）sqlcommand
                //    using (SqlCommand cmd = new SqlCommand(sql, con))
                //    {
                //        //6.开始执行SQL语句
                //        //3个命令对象
                //        //cmd.ExecuteNonQuery();方法有一个int型的返回值，表示执行insert、delete、update语句后所影响的行数，
                //        //并且只有执行这3种语句时返回影响的行数，其他语句都返回-1
                //        int r = cmd.ExecuteNonQuery();
                //        //cmd.ExecuteNonQuery();//执行insert、delete、update语句
                //        //cmd.ExecuteScalar();//执行返回单个结果
                //        //cmd.ExecuteReader();//查询出多行、多列结果
                //        //3.打开连接（连接对象最晚打开，最早关闭，节约资源）
                //        con.Open();
                //        Console.WriteLine("已成功插入{0}行数据", r);
                //    }
                //}
                //Console.ReadKey();
                #endregion
     
                #region 删除数据
                1.创建连接字符串
                //string constr = "Data Source=localhost;Initial Catalog=zwt;Integrated Security=True";
                2.连接对象
                //using (SqlConnection con = new SqlConnection(constr))
                //{
                //    //3.sql语句
                //    string sql = "delete from zwttable where name=tony";
                //    //4.创建sqlcommand对象
                //    using (SqlCommand cmd = new SqlCommand(sql, con))
                //    {
                //        //5.打开链接
                //        con.Open();
                //        //6.执行
                //        int r = cmd.ExecuteNonQuery();
                //        Console.WriteLine("成功删除了{0}行数据", r);
                //    }
                //}
                //Console.ReadKey();
                #endregion
     
                #region 修改数据
                1.创建连接字符串
                //string constr = "Data Source=localhost;Initial Catalog=zwt;Integrated Security=True";
                2.连接对象
                //using (SqlConnection con = new SqlConnection(constr))
                //{
                //    //3.sql语句
                //    string sql = "update zwttable set name=tony,age=26";
                //    //4.创建sqlcommand对象
                //    using (SqlCommand cmd = new SqlCommand(sql, con))
                //    {
                //        //5.打开链接
                //        con.Open();
                //        //6.执行
                //        int r = cmd.ExecuteNonQuery();
                //        Console.WriteLine("成功更新了{0}行数据", r);
                //    }
                //}
                //Console.ReadKey();
                #endregion
     
                #region 查询一条数据
                1.创建连接字符串
                //string constr = "Data Source=localhost;Initial Catalog=zwt;Integrated Security=True";
                2.连接对象
                //using (SqlConnection con = new SqlConnection(constr))
                //{
                //    //3.sql语句
                //    string sql = "select count(*) from zwttable";
                //    //4.创建sqlcommand对象
                //    using (SqlCommand cmd = new SqlCommand(sql, con))
                //    {
                //        //5.打开链接
                //        con.Open();
                //        //6.执行
                //        //sql语句执行时如果是聚合函数，ExecuteScalar()的返回不可能为null，如果不是聚合函数则需要判断是否为null
                //        //object count = (int)cmd.ExecuteScalar();
                //        //避免异常
                //        object count = Convert.ToInt32(cmd.ExecuteScalar());
                //        Console.WriteLine("zwttable表中共有{0}条数据", count);
                //    }
                //}
                //Console.ReadKey();
                #endregion
     
                #region 查询多条数据
                1.创建连接字符串
                //string constr = "Data Source=localhost;Initial Catalog=zwt;Integrated Security=True";
                2.连接对象
                //using (SqlConnection con = new SqlConnection(constr))
                //{
                //    //3.sql语句
                //    string sql = "select * from zwttable";
                //    //4.创建sqlcommand对象
                //    using (SqlCommand cmd = new SqlCommand(sql, con))
                //    {
                //        //5.打开链接
                //        con.Open();
                //        //通过调用ExecuteReader()方法，将给定的sql语句在服务器端执行
                //        //执行完毕后，服务器端已经查好数据，但数据保存在数据库服务器内存里。并没有返回给应用程序，
                //        //只是返回给应用程序一个reader对象，这个对象就是用来获取数据的对象
                //        using (SqlDataReader reader = cmd.ExecuteReader())
                //        {
                //            //接下来就是要通过reader对象一条一条获取数据
                //            //1.在获取数据前，先判断一下本次执行查询后，是否查到了数据
                //            if(reader.HasRows)//如果有数据为true,否则为false
                //            {
                //                //2.如果有数据，那么接下来就要一条条获取数据
                //                //每次获取数据之前，都要调用reader.Read()方法，向后移动一条数据，如果成功移动到了某条数据
                //                //上，则返回true，否则返回false
                //                while (reader.Read())
                //                {
                //                    //获取当前reader指向的数据
                //                    //reader.FieldCount可以获取当前查询语句查询到的列数
                //                    for (int i = 0; i < reader.FieldCount; i++)
                //                    {
                //                        Console.Write(reader[i]+"    |    ");
                //                    }
                //                    Console.WriteLine();
                //                }
                //            }
                //            else
                //            {
                //                Console.WriteLine("没有查到数据");
                //            }
                //        }
                //    }
                //}
                //Console.ReadKey();
                #endregion
            }
        }
    }

转自： [https://www.cnblogs.com/happyzwt/p/7712626.html][https_www.cnblogs.com_happyzwt_p_7712626.html]

[https_www.cnblogs.com_happyzwt_p_7712626.html]: https://www.cnblogs.com/happyzwt/p/7712626.html