C#结合数据库的数据采集器示例
本文所述为C#数据采集器，并结合有数据库操作，比较实用。读者可以进一步再完善一下写成一个更加成熟的数据采集程序。
具体功能代码如下：
usingSystem;
usingSystem.Collections.Generic;
usingSystem.ComponentModel;
usingSystem.Data;
usingSystem.Drawing;
usingSystem.Linq;
usingSystem.Text;
usingSystem.Windows.Forms;
usingSystem.Data.SqlClient;
usingSystem.IO;
namespaceCollectionEnginery
{
publicpartialclassForm1:Form
{
publicForm1()
{
InitializeComponent();
}
publicstaticSqlConnectionMy_con;//定义一个SqlConnection类型的公共变量My_con，用于判断数据库是否连接成功
publicstaticstringM_str_sqlcon="DataSource=.;Database=CollectionEnginery;Userid=sa;PWD=";
StreamReaderSReader;
#region建立数据库连接
///<summary>
///建立数据库连接.
///</summary>
///<returns>返回SqlConnection对象</returns>
publicstaticSqlConnectiongetcon()
{
My_con=newSqlConnection(M_str_sqlcon);//用SqlConnection对象与指定的数据库相连接
My_con.Open();//打开数据库连接
returnMy_con;//返回SqlConnection对象的信息
}
#endregion
#region创建DataSet对象
///<summary>
///创建一个DataSet对象
///</summary>
///<paramname="M_str_sqlstr">SQL语句</param>
///<paramname="M_str_table">表名</param>
///<returns>返回DataSet对象</returns>
publicDataSetgetDataSet(stringSQLstr,stringtableName)
{
getcon();//打开与数据库的连接
SqlDataAdapterSQLda=newSqlDataAdapter(SQLstr,My_con);//创建一个SqlDataAdapter对象，并获取指定数据表的信息
DataSetMy_DataSet=newDataSet();//创建DataSet对象
SQLda.Fill(My_DataSet,tableName);//通过SqlDataAdapter对象的Fill()方法，将数据表信息添加到DataSet对象中
con_close();//关闭数据库的连接
returnMy_DataSet;//返回DataSet对象的信息
}
#endregion
#region关闭数据库连接
///<summary>
///关闭于数据库的连接.
///</summary>
publicvoidcon_close()
{
if(My_con.State==ConnectionState.Open)//判断是否打开与数据库的连接
{
My_con.Close();//关闭数据库的连接
My_con.Dispose();//释放My_con变量的所有空间
}
}
#endregion
privatevoidForm1_Load(objectsender,EventArgse)
{
DataSetdataSet=newDataSet();
dataSet=getDataSet("select*fromtb_Collection","tb_Collection");
dataGridView1.DataSource=dataSet.Tables[0];
dataGridView1.Columns[0].HeaderText="编号";
dataGridView1.Columns[0].Width=40;
dataGridView1.Columns[1].HeaderText="书名";
dataGridView1.Columns[1].Width=140;
dataGridView1.Columns[2].HeaderText="条形码";
dataGridView1.Columns[2].Width=80;
dataGridView1.Columns[3].HeaderText="累加值";
dataGridView1.Columns[3].Width=80;
dataGridView1.Columns[4].HeaderText="总计";
dataGridView1.Columns[4].Width=40;
}
privatevoidbutton1_Click(objectsender,EventArgse)
{
stringtem_str="";//记录当前行
stringtem_code="";//条形码号
stringtem_mark="";//个数
stringtem_s="";
StreamReadervar_SRead=newStreamReader(Application.StartupPath+"\\AddData.dat");//实例化StreamReader，并打开指定的文件
while(true)//读取dat文件中的所有行
{
tem_str=var_SRead.ReadLine();//记录dat文件指定行的数据
tem_code=tem_str.Substring(0,tem_str.IndexOf(Convert.ToChar(tem_s))).Trim();//获取当前行的条形码
tem_mark=tem_str.Substring(tem_str.IndexOf(Convert.ToChar(tem_s)),tem_str.Length-tem_str.IndexOf(Convert.ToChar(tem_s))-1).Trim();//获取当前条形码的个数
for(inti=0;i<dataGridView1.RowCount-1;i++)//在dataGridView1控件中查找相应的条形码
{
if(dataGridView1.Rows[i].Cells[2].Value.ToString().Trim()==tem_code)//如查找到
{
dataGridView1.Rows[i].Cells[3].Value=tem_mark.ToString();//显示当前要添加的个数
dataGridView1.Rows[i].Cells[4].Value=Convert.ToInt32(dataGridView1.Rows[i].Cells[4].Value)+Convert.ToInt32(tem_mark);//计算当前条形码的总数
}
}
if(var_SRead.EndOfStream)//如果查询到文件尾
break;//退出循环
}
var_SRead.Close();//释放所有资源
}
}
}