web-form
查询数据库 ,从配置文件中读取字符信息 查询
// 从配置文件中读取数据 string sqlstr = // 获取数据库连接字符串ConfigurationManager.ConnectionStrings["staffConnectionString2"].ConnectionString; DataTable dt = new DataTable(); // 存储数据 using (SqlConnection conn = new SqlConnection(sqlstr)) // 连接数据库 { conn.Open(); // 打开数据库 using (SqlCommand cmd = conn.CreateCommand()) //sql 执行性句柄 { cmd.CommandText = "select * from tb_dept"; // 添加sql语句 SqlDataAdapter adapter = new SqlDataAdapter(cmd); // 执行句柄 adapter.Fill(dt); // 添加到表里面 } }
查询数据库,直接写字符串来连接 查询
string connectionString = "Data Source=MOGFPLQEEJOTGON\\SQLEXPRESS;Initial Catalog=staff;Integrated Security=True"; // 直接写sql语句 // 原来少了一个分号 // 表的名字弄错了 string selectDate = "select * from tb_emp where dept_id = @nodeValue"; using (SqlConnection conn = new SqlConnection(connectionString)) // 连接数据库 { using (SqlCommand cmd = new SqlCommand(selectDate, conn)) // 执行sql语句 { // 没有查到数据就是空的 cmd.Parameters.AddWithValue("@nodeValue", nodeValue);// 添加参数 SqlDataAdapter adapter = new SqlDataAdapter(cmd); // 查询数据将添加到数据表中 adapter.Fill(dt); } }
// 导致响应不生效了 重定向 //Response.Redirect("WebForm1.aspx"); // 转发保留之前的参数 转发 Server.Transfer("WebForm1.aspx");
数据库 修改
// 这还要转义一下不然后不去 string connectionString = "Data Source=MOGFPLQEEJOTGON\\SQLEXPRESS;Initial Catalog=staff;Integrated Security=True "; // 这样就可以解决这个问题了,只要能获取到这个参数就好 string param1 = Session["id"].ToString().Trim(); int params_id = Convert.ToInt32(param1); // 原来少了一个分号 string updateQuery = "update tb_emp set e_name = @name,dept_id= @dept_id,position = @position,phone= @phone,address= @address,emp_code= @emp_code where id = @params_id"; // using (SqlConnection conn = new SqlConnection(connectionString)) { using (SqlCommand cmd = new SqlCommand(updateQuery, conn)) { cmd.Parameters.AddWithValue("@name", name.Text.Trim()); cmd.Parameters.AddWithValue("@dept_id", dept_id.Text.Trim()); cmd.Parameters.AddWithValue("@phone", phone.Text.Trim()); cmd.Parameters.AddWithValue("@position", position.Text.Trim()); cmd.Parameters.AddWithValue("@address", address.Text.Trim()); cmd.Parameters.AddWithValue("@emp_code", emp_code.Text.Trim()); conn.Open(); int rowsAffected = cmd.ExecuteNonQuery(); if (rowsAffected > 0) {// 数据添加成功 重定向是服务器发送过来,没有数据了,页面不是第一次加载呢,那就没有绑定数据源 // 导致响应不生效了, //Response.Redirect("WebForm1.aspx"); // 转发保留之前的参数 Server.Transfer("WebForm1.aspx"); } else { // 数据添加失败 Response.StatusCode = 403; } } }
删除 数据库
// 这还要转义一下不然后不去 string connectionString = "Data Source=MOGFPLQEEJOTGON\\SQLEXPRESS;Initial Catalog=staff;Integrated Security=True"; // 原来少了一个分号 // 表的名字弄错了 string deteleQuery = "delete from tb_emp where id = @id"; int id = Convert.ToInt32(Session["id"].ToString().Trim()); using (SqlConnection conn = new SqlConnection(connectionString)) { using (SqlCommand cmd = new SqlCommand(deteleQuery, conn)) { cmd.Parameters.AddWithValue("@id",id ); conn.Open(); // 执行成功就返回非一的数, int rowsAffected = cmd.ExecuteNonQuery(); if (rowsAffected > 0) { // 删除添加成功 Response.Redirect("WebForm1.aspx"); } else { // 数据添加失败 Response.StatusCode = 403; } } }
添加 数据库
// 这还要转义一下不然后不去 string connectionString = "Data Source=MOGFPLQEEJOTGON\\SQLEXPRESS;Initial Catalog=staff;Integrated Security=True"; string insertQuery = "INSERT INTO tb_emp (e_name,dept_id,position,phone,address,emp_code)" + "VALUES (@name,@dept_id,@position,@phone,@address,@emp_code)"; using (SqlConnection conn = new SqlConnection(connectionString)) { using (SqlCommand cmd = new SqlCommand(insertQuery, conn)) { cmd.Parameters.AddWithValue("@name", name.Text.Trim()); cmd.Parameters.AddWithValue("@dept_id", dept_id.Text.Trim()); cmd.Parameters.AddWithValue("@phone", phone.Text.Trim()); cmd.Parameters.AddWithValue("@position", position.Text.Trim()); cmd.Parameters.AddWithValue("@address", address.Text.Trim()); cmd.Parameters.AddWithValue("@emp_code", emp_code.Text.Trim()); conn.Open(); int rowsAffected = cmd.ExecuteNonQuery(); if (rowsAffected > 0) { // 数据添加成功 Response.Redirect("WebForm1.aspx"); } else { // 数据添加失败 Response.StatusCode = 403; } } }