openfiledialog读取txt写入数据库示例
winform 中添加 openfiledialog button, winform .cs 中添加本地.mdf,如下:
using system;
using system.collections.generic;
using system.linq;
using system.windows.forms;
namespace txt记事本文件的读写
{
static class program
{
/// <summary>
/// 应用程序的主入口点。
/// </summary>
[stathread]
static void main()
{
//sqlserver 附加mdf文件
string datadir = appdomain.currentdomain.basedirectory;
if (datadir.endswith(@"\bin\debug\") || datadir.endswith(@"\bin\release\"))
{
datadir = system.io.directory.getparent(datadir).parent.parent.fullname;
appdomain.currentdomain.setdata("datadirectory", datadir);
}
application.enablevisualstyles();
application.setcompatibletextrenderingdefault(false);
application.run(new form1());
}
}
}
读取txt中的数据写入db:
using system;
using system.collections.generic;
using system.componentmodel;
using system.data;
using system.drawing;
using system.linq;
using system.text;
using system.windows.forms;
using system.data.sqlclient;
using system.io;
namespace txt记事本文件的读写
{
public partial class form1 : form
{
public form1()
{
initializecomponent();
}
private void btnreadtxt_click(object sender, eventargs e)
{
if (odfimport.showdialog() == dialogresult.ok)
{
using (sqlconnection conn = new sqlconnection(@"data source=.\sqlexpress;attachdbfilename=|datadirectory|\telphoneno.mdf;integrated security=true;user instance=true"))
{
conn.open();
using (filestream filestream = file.openread(odfimport.filename)) //打开txt文件
{
using (streamreader stmreader = new streamreader(filestream)) //读取txt文件
{
string line = null;
string telno = "";
string name = "";
string strins = "";
//sql 参数
strins = "insert into phoneno(telno,name) values(@telno,@name) ";
sqlparameter[] sqlpara = new sqlparameter[] {
new sqlparameter("telno",telno),
new sqlparameter("name",name)
};
//把读取出来的数据写入.mdf
using (sqlcommand sqlcmd = new sqlcommand(strins, conn))
{
//逐行读取
while ((line = stmreader.readline()) != null)
{
string[] strtel = line.split('-');
telno = strtel[0].tostring();
name = strtel[1].tostring();
sqlcmd.parameters.addrange(sqlpara);
sqlcmd.executenonquery();
sqlcmd.parameters.clear(); //参数清除
}
messagebox.show("导入成功", "read txt");
}
}
}
}
}
else
{
return;
}
}
}
}