C#连接数据库最基本操作之sql语句 DML

C#连接数据库最基本操作之sql语句 DML

            //1   连接字符串

            string connectionString

                = "server=127.0.0.1;integrated security=true;database=MSPetShop4";

            // = "server=.;uid=sa;pwd=SQL@5;database=AdventureWorks2012";

            // = "server=.;user id=sa;password=SQL@5;database=AdventureWorks2012";

            //2 实例化数据库连接

            System.Data.SqlClient.SqlConnection connection = new SqlConnection(connectionString);

            //也可以先实例化

            //System.Data.SqlClient.SqlConnection connection = new SqlConnection();

            //然后再设置ConnectionString 属性.

            //connection.ConnectionString = connectionString;

            try

            {

                //3 打开连接

                connection.Open();

                Console.WriteLine("成功连接数据计库MSPetShop4");

                //4 数据访问对象

                //sql字符串

                //string sql = "SELECT [客户],[产品],[数量] FROM A ";

                string sql = "insert into A(客户,产品,数量) values('biangongxin','阿特滋',2);";

                //SqlCommand 表示数据库要执行的sql命令

                System.Data.SqlClient.SqlCommand command = new SqlCommand(sql, connection);

                //ExecuteNonQuery 非查询语句

                //默认工作在自动事务之下,直接提交

                //执行sql DML 之前,手动开启

                System.Data.SqlClient.SqlTransaction trans =  connection.BeginTransaction();

                //设置命令所属的事务管理

                command.Transaction = trans;

                int result =  command.ExecuteNonQuery();

                Console.WriteLine(result);

                Console.Write("SQL命令已经提交,但是事务还未提交,是否继续执行(Y/N)");

                string ans = Console.ReadLine();

                if (ans.Substring(, ).ToUpper() == "Y")

                {

                    //提交事务

                    trans.Commit();

                }

                else

                {

                    //回滚事务;

                    trans.Rollback();

                }

            }

            catch(System.Data.SqlClient.SqlException exception)

            {

                Console.WriteLine(exception.Message);

            }

            finally

            {

                //4 注销连接

                connection.Dispose();

                Console.WriteLine("成功断开数据计库MSPetShop4");

            }

            Console.ReadLine();