扫描文件夹导入数据库，然后进行数据查询

E:/pvfhv/index1下的文件内容如下：

1000-1009-1
2000-2009-2
3000-3009-3
4000-4009-4
5000-5009-5
6000-6009-6
7000-7009-7

 

E:/pvfhv/index2下的文件内容如下：

1-联想集团笔记本
2-方正集团台式机
3-ibm的服务器
4-海尔集团的洗衣机

 

如上图所示布局

导入按钮代码：

FolderBrowserDialog fbd = new FolderBrowserDialog(); if (fbd.ShowDialog() == DialogResult.OK) { string filepath = fbd.SelectedPath; //得到filepasth文件夹下的所有文件的地址数组如{e:/数据/张.txt,e:/数据/王.txt} string[] fileaddresses = Directory.GetFiles(filepath, "*.txt", SearchOption.AllDirectories); //连接数据库的字符串 string connStr = ConfigurationManager.ConnectionStrings["connStr"].ConnectionString; using (SqlConnection conn = new SqlConnection(connStr)) { conn.Open(); //计数器 int count = 0; foreach (var fileaddress in fileaddresses) { //获取选定文件夹下的文件名称即：张，王这样的文件名不带扩展名和路径 string filename = Path.GetFileNameWithoutExtension(fileaddress); using (FileStream filestream = File.OpenRead(fileaddress)) { StreamReader streamreader = new StreamReader(filestream, Encoding.Default);//防止乱码 string line = null; while ((line = streamreader.ReadLine()) != null) { string[] strs = line.Split('-'); string startNo = strs[0]; string endNo = strs[1]; string companyname = strs[2]; SqlCommand cmd = conn.CreateCommand(); cmd.CommandText = "insert into products(startNo,endNo,companyName) values(@startNo,@endNo,@companyName)"; cmd.Parameters.AddWithValue("startNo", startNo); cmd.Parameters.AddWithValue("endNo", endNo); cmd.Parameters.AddWithValue("companyName", filename+"的"+companyname+"产品"); cmd.ExecuteNonQuery(); count++; } } } MessageBox.Show(count+"条数据导入成功"); } } else { return; }

查询按钮的代码：

string connStr = ConfigurationManager.ConnectionStrings["connStr"].ConnectionString; if (string.IsNullOrEmpty(txtboxdigital.Text) == false) { using (SqlConnection conn = new SqlConnection(connStr)) { conn.Open(); SqlCommand cmd = conn.CreateCommand(); cmd.CommandText = "select * from products where @userinput between startNo and endNo"; cmd.Parameters.AddWithValue("userinput", txtboxdigital.Text); using (SqlDataReader reader = cmd.ExecuteReader()) { if (reader.Read()) { string dbcompanyName = reader.GetString(reader.GetOrdinal("companyName")); MessageBox.Show(dbcompanyName); } else { MessageBox.Show("没有这个数据！"); } } } } else { MessageBox.Show("查询文字不能为空"); }

文本文件查询按钮代码：

//定义是否找到 bool find = false; //获取产品列表 string[] productlist = Directory.GetFiles(@"E:/pvfhv/index2", "*.txt", SearchOption.AllDirectories); foreach (var list in productlist) { using (FileStream productstream = File.OpenRead(list)) { StreamReader sreader = new StreamReader(productstream,Encoding.Default); string productline = null; while ((productline = sreader.ReadLine()) != null) { string[] pstrs = productline.Split('-'); //产品的编号 string proid = pstrs[0]; //产品的名称 string proname = pstrs[1]; //获取产品对应的查询号码段文件内容 string[] numberfiles = Directory.GetFiles(@"E:/pvfhv/index1", "*.txt", SearchOption.AllDirectories); foreach (var numberfile in numberfiles) { using (FileStream numberstream = File.OpenRead(numberfile)) { StreamReader nreader = new StreamReader(numberstream,Encoding.Default);//防止乱码 string numberline = null; while ((numberline = nreader.ReadLine()) != null) { string[] nlines = numberline.Split('-'); //起始号码 string startNo = nlines[0]; //结束号码 string endNo = nlines[1]; //产品编号 string pid = nlines[2]; //对用户输入的数码进行查询处理 string userinput=txtnumber.Text.Trim(); if (string.IsNullOrEmpty(userinput)==false) { if ((userinput.CompareTo(startNo) >= 0 && userinput.CompareTo(endNo) <= 0) && (pid == proid)) { MessageBox.Show("你所查询的是：" + proname); return; } } else { MessageBox.Show("输入的数码不能为空"); } } } } } }