使用LINQ技术查询DATASET中的单个表privatevoidForm1_Load(objectsender,EventArgse){stringConnectionStrin
private void Form1_Load(object sender, EventArgs e)
{
string ConnectionString &＃61; "Data Source&＃61;DESKTOP-M4PUOAS\\SQLEXPRESS;Initial Catalog&＃61;db_TomeTwo;User ID&＃61;sa;Password&＃61;wh1090220084";//声明连接字符串
using (SqlConnection conn &＃61; new SqlConnection(ConnectionString))//创建数据库连接对象
{
string sqlstr &＃61; "select * from tb_Bookinfo";//定义查询语句
SqlDataAdapter da &＃61; new SqlDataAdapter(sqlstr, conn);//创建数据桥接器对象
DataSet ds &＃61; new DataSet();//创建数据对象
da.Fill(ds, "tb_Bookinfo");//填充数据集
//查找3月份出版的图书
var result &＃61; from b in ds.Tables["tb_Bookinfo"].AsEnumerable()
where b.Field("b_pub_date").Month &＃61;&＃61; 3
select new
{
bookname &＃61; b["b_name"].ToString(),
author &＃61; b["b_pub_date"].ToString()
};
foreach (var item in result)//遍历图书的书名和出版日期
{
richTextBox1.Text &＃43;&＃61;"书名&＃xff1a;" &＃43; item.bookname &＃43; ";出版日期&＃xff1a;" &＃43; item.author&＃43;"\n";
}
}
}
二、使用LINQ技术对DataSet进行投影操作
本例只要用到了DataRowExtensions类的Field泛型方法
Field方法用来提供对指定行中的每个列值的强类型访问&＃xff0c;其语法格式如下&＃xff1a;
Public static T Filed(this DataRow row,string columnName)
参数说明&＃xff1a;
- row&＃xff1a;表示当前访问的列名称。
- columnName::表示访问的列名称。
- 返回值&＃xff1a;由columnName指定的DataColumn的值&＃xff0c;类型为T
private void Frm_Main_Load(object sender, EventArgs e)
{
string ConnectionString &＃61; "Data Source&＃61;DESKTOP-M4PUOAS\\SQLEXPRESS;Initial Catalog&＃61;db_TomeTwo;User ID&＃61;sa;Password&＃61;wh1090220084";//声明连接字符串
using (SqlConnection Conn &＃61; new SqlConnection(ConnectionString))//创建数据库连接对象
{
string sqlstr &＃61; "select top 5* from tb_Bookinfo";//定义查询语句
SqlDataAdapter da &＃61; new SqlDataAdapter(sqlstr, Conn);//创建数据桥接器对象
DataSet ds &＃61; new DataSet();//创建数据对象
da.Fill(ds, "tb_Bookinfo");//填充数据集
//查询图书信息表前3行数据的图书名称和作者
var result &＃61; from b in ds.Tables["tb_Bookinfo"].AsEnumerable()
select new
{
b_name &＃61; b.Field("b_name"),
b_author &＃61; b.Field("b_author")
};
foreach (var item in result)//遍历输出查询结果
{
richTextBox1.Text &＃43;&＃61;"图书名称&＃xff1a;" &＃43; item.b_name &＃43; " ****** 作者&＃xff1a;" &＃43; item.b_author&＃43;"\n";
}
}
}
三、使用LINQ技术查询DataSet 中的多个表
private void Frm_Main_Load(object sender, EventArgs e)
{
string ConnectionString &＃61; "Data Source&＃61;DESKTOP-M4PUOAS\\SQLEXPRESS;Initial Catalog&＃61;db_TomeTwo;User ID&＃61;sa;Password&＃61;wh1090220084";//声明连接字符串
using (SqlConnection Conn &＃61; new SqlConnection(ConnectionString))//创建数据库连接对象
{
string sqlstr &＃61; "select * from tb_Register";//定义查询语句
SqlDataAdapter da &＃61; new SqlDataAdapter(sqlstr, Conn);//创建数据桥接器对象
DataSet ds &＃61; new DataSet();//创建数据对象
da.Fill(ds, "register");//填充第一个数据表数据到DataSet
sqlstr &＃61; "select * from tb_Sale";//定义查询语句
da.SelectCommand.CommandText &＃61; sqlstr;//指定第二条查询语句
da.Fill(ds, "sale");//填充第二个数据表数据到DataSet
//查询有销售记录的药品信息
var result &＃61; from r in ds.Tables["register"].AsEnumerable()
join s in ds.Tables["sale"].AsEnumerable()
on r.Field("药品编号") equals s.Field("药品编号")
select new
{
drug_name &＃61; r["药品名称"].ToString(),
drug_factory &＃61; r["生产厂家"].ToString(),
drug_sale &＃61; s["销售额"].ToString()
};
foreach (var item in result) //遍历输出查询结果
{
richTextBox1.Text &＃43;&＃61; "药品名称&＃xff1a;" &＃43; item.drug_name &＃43; "******生产厂家&＃xff1a;" &＃43; item.drug_factory &＃43; "******销售额&＃xff1a;" &＃43; item.drug_sale &＃43; "\n";
}
}
}
四、使用LINQ技术对DataSet进行排序操作
private void Frm_Main_Load(object sender, EventArgs e)
{
string ConnectionString &＃61; "server&＃61;WIN-GI7E47AND9R\\LS; database&＃61;db_TomeTwo; uid&＃61;sa; pwd&＃61;";//连接字符串
using (SqlConnection Conn &＃61; new SqlConnection(ConnectionString))//创建数据库连接对象
{
string sqlstr &＃61; "select * from tb_Bookinfo";//定义查询语句
SqlDataAdapter da &＃61; new SqlDataAdapter(sqlstr, Conn);//创建数据桥接器对象
DataSet ds &＃61; new DataSet();//创建数据对象
da.Fill(ds, "tb_Bookinfo");//填充数据集
//按照单价降序排序
var result &＃61; from b in ds.Tables["tb_Bookinfo"].AsEnumerable()
orderby b.Field("b_price") descending
select new
{
b_name &＃61; b["b_name"].ToString(),
b_price &＃61; b["b_price"].ToString()
};
foreach (var item in result)//遍历输出查询结果
{
richTextBox1.Text&＃43;&＃61;"图书名称&＃xff1a;" &＃43; item.b_name &＃43; " ****** 单价&＃xff1a;" &＃43; item.b_price&＃43;"\n";
}
}
}
五、使用TakeWhile提取满足条件的记录
private void Frm_Main_Load(object sender, EventArgs e)
{
string conStr &＃61; "Data Source&＃61;WIN-GI7E47AND9R\\LS;Database&＃61;db_TomeTwo;UID&＃61;sa;Pwd&＃61;;";//取连接字符串
string sql &＃61; "select * from EmployeeInfo";//构造sql语句
DataSet ds &＃61; new DataSet();//创建数据集
using (SqlConnection con &＃61; new SqlConnection(conStr))//创建数据连接
{
SqlCommand cmd &＃61; new SqlCommand(sql, con);//创建Command对象
SqlDataAdapter sda &＃61; new SqlDataAdapter(cmd);//创建DataAdapter对象
sda.Fill(ds, "EmployeeInfo");//填充数据集
}
//从头开始提取生日小于2009-7-1之前的员工信息
IEnumerable query &＃61; ds.Tables["EmployeeInfo"].AsEnumerable().TakeWhile(itm &＃61;> itm.Field("Birthday") dataGridView1.DataSource &＃61; query.CopyToDataTable();//设置dataGridView1数据源
}
六、使用SkipWhile跳过指定条件的记录
private void Frm_Main_Load(object sender, EventArgs e)
{
string conStr &＃61; "Data Source&＃61;WIN-GI7E47AND9R\\LS;Database&＃61;db_TomeTwo;UID&＃61;sa;Pwd&＃61;;";//取连接字符串
string sql &＃61; "select * from EmployeeInfo";//构造sql语句
DataSet ds &＃61; new DataSet();//创建数据集
using (SqlConnection con &＃61; new SqlConnection(conStr))//创建数据连接
{
SqlCommand cmd &＃61; new SqlCommand(sql, con);//创建Command对象
SqlDataAdapter sda &＃61; new SqlDataAdapter(cmd);//创建DataAdapter对象
sda.Fill(ds, "EmployeeInfo");//填充数据集
}
//跳过生日小于2009-7-1的员工信息
IEnumerable query &＃61; ds.Tables["EmployeeInfo"].AsEnumerable().SkipWhile(itm &＃61;> itm.Field("Birthday") dataGridView1.DataSource &＃61; query.CopyToDataTable();//设置dataGridView1数据源
}
京公网安备 11010802041100号