FolderBrowserDialog fbd = new FolderBrowserDialog();//创建一个选择文件的对话框
if (fbd.ShowDialog() == DialogResult.OK)
{
//string sqlstr = ConfigurationManager.ConnectionStrings["ConnStr"].ConnectionString;
string sqlstr = "Data Source=.;Initial Catalog=lianxi;User Id=sa;password=sa;";
string path = fbd.SelectedPath;
string[] files = Directory.GetFiles(path, "*.txt", SearchOption.AllDirectories);//检索路径下的txt文件,将路径和文件名放入files数组中
string[] lines = null;
using (SqlConnection conn = new SqlConnection(sqlstr))
{
conn.Open();
foreach (string file in files)
{
if ((lines = File.ReadAllLines(file, Encoding.Default)) != null)//读取每一个file,整个file返回一个字符数组
{
foreach (string line in lines)//对每一行进行操作
{
string[] strs = line.Split('-');
string name = strs[0];
int age = Convert.ToInt32(strs[1]);
using (SqlCommand cmd = conn.CreateCommand())
{
cmd.CommandText = "insert into T_Person(name,age) values(@name,@age)";
cmd.Parameters.Add("@name", name);
cmd.Parameters.Add("@age", age);
//cmd.Parameters.Add("@name")=name;
//cmd.Parameters.Add("@age")=age;
cmd.ExecuteNonQuery();
}
}
}
}
}
}
MessageBox.Show("数据导入完成。");
|