[传智播客学习日记]ADO.Net连接与增删改查

今天学习基本的ADO，就是通过C#程序代码来操控数据库，其实说白了还是一堆函数，程序可越来越有英语课的感觉了。

为了省事，不写try什么的了。首先是最基本的登录和断开连接：

#region 登陆数据库
//创建一个连接对象
SqlConnection con = new SqlConnection();

//连接字符串（可以在左边服务器资源管理器里自动生成）：
//Data source=服务器名（IP地址）\实例名;
//Initial Catalog=数据库名;
//Integrated Security=True    集成身份验证
//User ID=xxx;Password=xxx    用户名密码登陆
string constr = @"Data source=IT-129\SQLEXPRESS;Initial Catalog=ItCastCn;Integrated Security=True";

//让字符串和SqlConnection对象关联
con.ConnectionString = constr;

//打开连接（避免重复打开）
if (con.State == System.Data.ConnectionState.Closed)
{
    con.Open();
}
#endregion

#region 关闭数据库
//关闭连接
con.Close();

//释放非托管资源
con.Dispose();
#endregion

增删改都要使用SqlCommand的ExecuteNonQuery方法，下面这个例子从窗体中读取用户输入，并且修改数据库：

private void button1_Click(object sender, EventArgs e)
{
    //从控件中取得字符串
    string autoId = txt_autoId.Text.Trim();
    string BrandName = txt_BrandName.Text.Trim();
    string Price = txt_Price.Text.Trim();

    //建立连接字符串
    string constr = @"Data source=IT-129\SQLEXPRESS;Initial Catalog=ItCastCn;Integrated Security=True";

    //新建一个SqlConnection对象con对数据库进行控制（连接器）
    using (SqlConnection con = new SqlConnection(constr))
    {
        //定义SQL语句
        string sql = string.Format
        (
            "update T1 " +
            "set BrandName='{0}', price={1} " +
            "where autoId = {2}" ,
            BrandName, Price, autoId
        );

        //定义一个SqlCommand对象cmd（操作器），参数是SQL语句和连接器
        using (SqlCommand cmd = new SqlCommand(sql, con))
        {
        //Open操作尽量晚
        if (con.State == System.Data.ConnectionState.Closed)
        {
                con.Open();
        }
            //执行SQL语句，返回影响了几条
            int r = cmd.ExecuteNonQuery();
                    
            //Close操作尽量早
            con.Close();
            MessageBox.Show("已成功修改" + r + "条语句！");
        }
    }
}

使用SqlDataReader输出整个表，假设一个表里有3列：

using (SqlConnection con = new SqlConnection(constr))
{
    string sql = "select * from dbo.ClassInfo";
                
    using (SqlCommand cmd = new SqlCommand(sql, con))
    {
        if (con.State == System.Data.ConnectionState.Closed)
        {
            con.Open();
        }

        //这句话执行后并没有返回，存放在服务器的内存里
        SqlDataReader reader = cmd.ExecuteReader();
        using (reader)
        {
            if (reader.HasRows)
            {
                //读取每一行
                while (reader.Read())
                {
                    //读取每一列
                    //object obj1 = reader.GetValue(0);
                    //object obj2 = reader.GetValue(1);
                    //object obj3 = reader.GetValue(2);

                    //下标方式，可以根据列名取数据
                    //object obj1 = reader["ClassId"];
                    //object obj2 = reader[1]; 
                    //object obj3 = reader[2];

                    //建议使用这种强类型的方式提高性能
                    int obj1 = reader.GetInt32(0);
                    string obj2 = reader.GetString(1);
                    string obj3 = reader.GetString(2);

                    Console.WriteLine("{0}\t|\t{1}\t|\t{2}", obj1, obj2, obj3);
                }
            }
            else
            {
                Console.WriteLine("x");
            }
        }

        con.Close();
    }
}

如果在一条SQL语句当中有变量（以@开头），则可以这样：

cmd.Parameters.AddWithValue("@SQL变量名",值）;