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(0, 1).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();