c#如何读取规定格式的TXT文件,并存入数据库
txt文件格式如下江苏卫视2009/12/706:35电视剧家有儿女(第一部)07:00江苏新时空07:20人间精选07:50媳妇的眼泪(33)2009/12/706:3...
txt文件格式如下
江苏卫视
2009/12/7
06:35 电视剧 家有儿女(第一部)
07:00 江苏新时空
07:20 人间精选
07:50 媳妇的眼泪(33)
2009/12/7
06:35 电视剧 家有儿女(第一部)
07:00 江苏新时空
07:20 人间精选
07:50 媳妇的眼泪(33)
希望能给出详细解决办法,不胜感激!!在线等,急急急!!!
要求时间和节目单能分开存储! 格式如下:
数据库字段
datetime program
2009-12-7 06:35 电视剧 家有儿女(第一部)
2009-12-7 07:00 江苏新时空
2009-12-7 07:50 人间精选
麻烦能帮我写出源码来,不胜感激!!! 展开
江苏卫视
2009/12/7
06:35 电视剧 家有儿女(第一部)
07:00 江苏新时空
07:20 人间精选
07:50 媳妇的眼泪(33)
2009/12/7
06:35 电视剧 家有儿女(第一部)
07:00 江苏新时空
07:20 人间精选
07:50 媳妇的眼泪(33)
希望能给出详细解决办法,不胜感激!!在线等,急急急!!!
要求时间和节目单能分开存储! 格式如下:
数据库字段
datetime program
2009-12-7 06:35 电视剧 家有儿女(第一部)
2009-12-7 07:00 江苏新时空
2009-12-7 07:50 人间精选
麻烦能帮我写出源码来,不胜感激!!! 展开
展开全部
这个很简单啊 你以一行的形式读取 然后 拿到这行以后 判断这行的格式是否有日期 如果有的话 那麼就是 2009/12/7 否则就是 06:35 电视剧 家有儿女(第一部)
如果你要源码的话我可以现在给你写 有问题HI我 !!
//得到节目TXT
StreamReader sr = new StreamReader("D:\\jiangsu.txt", Encoding.GetEncoding("GBK"));
//读取到末尾
string txt = sr.ReadToEnd();
//电视台
string dianshitai = string.Empty;
//判断是否为空文本
if (!txt.Equals(string.Empty))
{
//分割文本
string[] oldString = txt.Replace("\r\n", "@").Split('@');
//循环数组
foreach (string newTxt in oldString)
{
//是否日期
if (newTxt.IndexOf("/") > 0)
{
//得到日期
}
//是否节目
else if (newTxt.IndexOf(":"))
{
//得到节目
}
//电视台
else
{
//得到电视台
dianshitai = newTxt;
}
}
//再怎麼操作数据库不用教了吧?
如果你要源码的话我可以现在给你写 有问题HI我 !!
//得到节目TXT
StreamReader sr = new StreamReader("D:\\jiangsu.txt", Encoding.GetEncoding("GBK"));
//读取到末尾
string txt = sr.ReadToEnd();
//电视台
string dianshitai = string.Empty;
//判断是否为空文本
if (!txt.Equals(string.Empty))
{
//分割文本
string[] oldString = txt.Replace("\r\n", "@").Split('@');
//循环数组
foreach (string newTxt in oldString)
{
//是否日期
if (newTxt.IndexOf("/") > 0)
{
//得到日期
}
//是否节目
else if (newTxt.IndexOf(":"))
{
//得到节目
}
//电视台
else
{
//得到电视台
dianshitai = newTxt;
}
}
//再怎麼操作数据库不用教了吧?
展开全部
方法一:
private string connStr = ConfigurationManager.ConnectionStrings["connstr"].ConnectionString;
/// <summary>
/// 用insert方法从文本文件中批量导入到数据库表中
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
private void btnInsert_Click(object sender, RoutedEventArgs e)
{
OpenFileDialog ofd = new OpenFileDialog();
ofd.Filter = "文本文档|*.txt";
//如果用户没有选择文件并确定则直接返回
if (ofd.ShowDialog() != true)
{
return;
}
//获得文件名包括路径
string fileName = ofd.FileName;
try
{
//定义一个开始时间
DateTime startTime = DateTime.Now;
//因为文件比较大,所有使用StreamReader的效率要比使用File.ReadLines高
using (StreamReader sr = new StreamReader(fileName, Encoding.Default))
{
using (SqlConnection conn = new SqlConnection(connStr))
{
conn.Open();
using (SqlCommand cmd = conn.CreateCommand())
{
while (!sr.EndOfStream)
{
string readStr = sr.ReadLine();//读取一行数据
if (readStr.StartsWith("1"))//去掉标题行
{
string[] strs = readStr.Split(new char[] { '\t', '"' }, StringSplitOptions.RemoveEmptyEntries);//将读取的字符串按"制表符/t“和””“分割成数组
string startNum = strs[0];
string numArea = strs[1];
string numType = strs[2];
cmd.CommandText = "insert into T_PhoneInfo(FStartNum,FNumArea,FNumType) values(@startNum,@numArea,@numType)";
cmd.Parameters.Clear();//清除上一次的参数
cmd.Parameters.Add(new SqlParameter("@startNum", startNum));
cmd.Parameters.Add(new SqlParameter("@numArea", numArea));
cmd.Parameters.Add(new SqlParameter("@numType", numType));
cmd.ExecuteNonQuery();
}
}
}
}
}
//结束时间-开始时间=总共花费的时间
TimeSpan ts = DateTime.Now - startTime;
MessageBox.Show("导入数据成功!共花费时间:" + ts.ToString());
}
catch (IOException ex)
{
MessageBox.Show(ex.Message);
}
catch (Exception ex)
{
MessageBox.Show(ex.Message);
}
}
方法二:
private void btnSqlBulkCopy_Click(object sender, RoutedEventArgs e)
{
OpenFileDialog ofd = new OpenFileDialog();
ofd.Filter = "文本文档|*.txt";
//如果用户没有选择文件并确定则直接返回
if (ofd.ShowDialog() != true)
{
return;
}
//获得文件名包括路径
string fileName = ofd.FileName;
try
{
//定义一个开始时间
DateTime startTime = DateTime.Now;
//创建内存临时数据表来存储从文本文件中读取出来的数据
using (DataTable table = new DataTable())
{
//为数据表创建相对应的数据列
table.Columns.Add("startNum");
table.Columns.Add("numArea");
table.Columns.Add("numType");
//因为文件比较大,所有使用StreamReader的效率要比使用File.ReadLines高
using (StreamReader sr = new StreamReader(fileName, Encoding.Default))
{
while (!sr.EndOfStream)
{
DataRow dr = table.NewRow();//创建数据行
string readStr = sr.ReadLine();//读取一行数据
if (readStr.StartsWith("1"))//去掉标题行
{
string[] strs = readStr.Split(new char[] { '\t', '"' }, StringSplitOptions.RemoveEmptyEntries);//将读取的字符串按"制表符/t“和””“分割成数组
string startNum = strs[0];
string numArea = strs[1];
string numType = strs[2];
//往对应的 行中添加数据
dr["startNum"] = startNum;
dr["numArea"] = numArea;
dr["numType"] = numType;
table.Rows.Add(dr);//将创建的数据行添加到table中
}
}
}
SqlBulkCopy bulkCopy = new SqlBulkCopy(connStr);
bulkCopy.DestinationTableName = "T_PhoneInfo";//设置数据库中对象的表名
//设置数据表table和数据库中表的列对应关系
bulkCopy.ColumnMappings.Add("startNum", "FStartNum");
bulkCopy.ColumnMappings.Add("numArea", "FNumArea");
bulkCopy.ColumnMappings.Add("numType", "FNumType");
bulkCopy.WriteToServer(table);//将数据表table复制到数据库中
TimeSpan ts = DateTime.Now - startTime;
MessageBox.Show("共导入" +table.Rows.Count+ "条数据,总共花费时间:" + ts.ToString());
}
}
catch (IOException ex)
{
MessageBox.Show(ex.Message);
}
catch (Exception ex)
{
MessageBox.Show(ex.Message);
}
}
引用自:http://www.cnblogs.com/sixstar01/archive/2012/12/13/2817314.html
private string connStr = ConfigurationManager.ConnectionStrings["connstr"].ConnectionString;
/// <summary>
/// 用insert方法从文本文件中批量导入到数据库表中
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
private void btnInsert_Click(object sender, RoutedEventArgs e)
{
OpenFileDialog ofd = new OpenFileDialog();
ofd.Filter = "文本文档|*.txt";
//如果用户没有选择文件并确定则直接返回
if (ofd.ShowDialog() != true)
{
return;
}
//获得文件名包括路径
string fileName = ofd.FileName;
try
{
//定义一个开始时间
DateTime startTime = DateTime.Now;
//因为文件比较大,所有使用StreamReader的效率要比使用File.ReadLines高
using (StreamReader sr = new StreamReader(fileName, Encoding.Default))
{
using (SqlConnection conn = new SqlConnection(connStr))
{
conn.Open();
using (SqlCommand cmd = conn.CreateCommand())
{
while (!sr.EndOfStream)
{
string readStr = sr.ReadLine();//读取一行数据
if (readStr.StartsWith("1"))//去掉标题行
{
string[] strs = readStr.Split(new char[] { '\t', '"' }, StringSplitOptions.RemoveEmptyEntries);//将读取的字符串按"制表符/t“和””“分割成数组
string startNum = strs[0];
string numArea = strs[1];
string numType = strs[2];
cmd.CommandText = "insert into T_PhoneInfo(FStartNum,FNumArea,FNumType) values(@startNum,@numArea,@numType)";
cmd.Parameters.Clear();//清除上一次的参数
cmd.Parameters.Add(new SqlParameter("@startNum", startNum));
cmd.Parameters.Add(new SqlParameter("@numArea", numArea));
cmd.Parameters.Add(new SqlParameter("@numType", numType));
cmd.ExecuteNonQuery();
}
}
}
}
}
//结束时间-开始时间=总共花费的时间
TimeSpan ts = DateTime.Now - startTime;
MessageBox.Show("导入数据成功!共花费时间:" + ts.ToString());
}
catch (IOException ex)
{
MessageBox.Show(ex.Message);
}
catch (Exception ex)
{
MessageBox.Show(ex.Message);
}
}
方法二:
private void btnSqlBulkCopy_Click(object sender, RoutedEventArgs e)
{
OpenFileDialog ofd = new OpenFileDialog();
ofd.Filter = "文本文档|*.txt";
//如果用户没有选择文件并确定则直接返回
if (ofd.ShowDialog() != true)
{
return;
}
//获得文件名包括路径
string fileName = ofd.FileName;
try
{
//定义一个开始时间
DateTime startTime = DateTime.Now;
//创建内存临时数据表来存储从文本文件中读取出来的数据
using (DataTable table = new DataTable())
{
//为数据表创建相对应的数据列
table.Columns.Add("startNum");
table.Columns.Add("numArea");
table.Columns.Add("numType");
//因为文件比较大,所有使用StreamReader的效率要比使用File.ReadLines高
using (StreamReader sr = new StreamReader(fileName, Encoding.Default))
{
while (!sr.EndOfStream)
{
DataRow dr = table.NewRow();//创建数据行
string readStr = sr.ReadLine();//读取一行数据
if (readStr.StartsWith("1"))//去掉标题行
{
string[] strs = readStr.Split(new char[] { '\t', '"' }, StringSplitOptions.RemoveEmptyEntries);//将读取的字符串按"制表符/t“和””“分割成数组
string startNum = strs[0];
string numArea = strs[1];
string numType = strs[2];
//往对应的 行中添加数据
dr["startNum"] = startNum;
dr["numArea"] = numArea;
dr["numType"] = numType;
table.Rows.Add(dr);//将创建的数据行添加到table中
}
}
}
SqlBulkCopy bulkCopy = new SqlBulkCopy(connStr);
bulkCopy.DestinationTableName = "T_PhoneInfo";//设置数据库中对象的表名
//设置数据表table和数据库中表的列对应关系
bulkCopy.ColumnMappings.Add("startNum", "FStartNum");
bulkCopy.ColumnMappings.Add("numArea", "FNumArea");
bulkCopy.ColumnMappings.Add("numType", "FNumType");
bulkCopy.WriteToServer(table);//将数据表table复制到数据库中
TimeSpan ts = DateTime.Now - startTime;
MessageBox.Show("共导入" +table.Rows.Count+ "条数据,总共花费时间:" + ts.ToString());
}
}
catch (IOException ex)
{
MessageBox.Show(ex.Message);
}
catch (Exception ex)
{
MessageBox.Show(ex.Message);
}
}
引用自:http://www.cnblogs.com/sixstar01/archive/2012/12/13/2817314.html
已赞过
已踩过<
评论
收起
你对这个回答的评价是?
展开全部
读取txt文件并存储很好实现
但是你这种格式,读的时候太麻烦
你用这种格式存储在txt文件里,那就简单的多了
2009/12/7 06:35 电视剧 家有儿女(第一部)
2009/12/7 07:00 江苏新时空
2009/12/7 07:20 人间精选
2009/12/7 07:50 媳妇的眼泪(33)
注意他们之间有空格。
当然你那种格式当然也能实现。知识麻烦了许多
这是我以前写过的类似代码,你试验下行不行吧
FileStream afile = new FileStream("路径", FileMode.OpenOrCreate);
StreamReader sr = new StreamReader(afile,Encoding.Default);
string str = sr.ReadLine();
string[] strarr;
string stime;
string smenu;
while (str!=null)
{
strarr = str.Split(',');
stime=strarr[0];
smenu=strarr[1];
sqlhelper.insert(stime,smenu);//这是数据存储的部分
str = sr.ReadLine();
}
sr.Close();
另外可能不止这一种方法,譬如先将数据全部读到内存,然后在执行存储。
但是你这种格式,读的时候太麻烦
你用这种格式存储在txt文件里,那就简单的多了
2009/12/7 06:35 电视剧 家有儿女(第一部)
2009/12/7 07:00 江苏新时空
2009/12/7 07:20 人间精选
2009/12/7 07:50 媳妇的眼泪(33)
注意他们之间有空格。
当然你那种格式当然也能实现。知识麻烦了许多
这是我以前写过的类似代码,你试验下行不行吧
FileStream afile = new FileStream("路径", FileMode.OpenOrCreate);
StreamReader sr = new StreamReader(afile,Encoding.Default);
string str = sr.ReadLine();
string[] strarr;
string stime;
string smenu;
while (str!=null)
{
strarr = str.Split(',');
stime=strarr[0];
smenu=strarr[1];
sqlhelper.insert(stime,smenu);//这是数据存储的部分
str = sr.ReadLine();
}
sr.Close();
另外可能不止这一种方法,譬如先将数据全部读到内存,然后在执行存储。
已赞过
已踩过<
评论
收起
你对这个回答的评价是?
展开全部
private void button1_Click(object sender, EventArgs e)
{
con.Open();//con为你的SqlConnection对象
StreamReader sr = new StreamReader(new FileStream("a.txt", FileMode.Open));
while (!sr.EndOfStream)
{
string data = sr.ReadLine().Replace(" ", "");//除去该行数据中的空格
string insertStr = "insert into t1(ziduan)values('" + data.Substring(0, 1) + "')";
SqlCommand insert = new SqlCommand(insertStr, con);
insert.ExecuteNonQuery();
insertStr = "insert into t2(ziduan)values('" + data.Substring(1, 1) + "')";
insert = new SqlCommand(insertStr, con);
insert.ExecuteNonQuery();
insertStr = "insert into t3(ziduan)values('" + data.Substring(2, 1) + "')";
insert = new SqlCommand(insertStr, con);
insert.ExecuteNonQuery();
}
sr.Close();
con.Close();
MessageBox.Show("插入数据已完成!");
}
注意要加上这两个命名空间:
using System.IO;
using System.Data.SqlClient;
{
con.Open();//con为你的SqlConnection对象
StreamReader sr = new StreamReader(new FileStream("a.txt", FileMode.Open));
while (!sr.EndOfStream)
{
string data = sr.ReadLine().Replace(" ", "");//除去该行数据中的空格
string insertStr = "insert into t1(ziduan)values('" + data.Substring(0, 1) + "')";
SqlCommand insert = new SqlCommand(insertStr, con);
insert.ExecuteNonQuery();
insertStr = "insert into t2(ziduan)values('" + data.Substring(1, 1) + "')";
insert = new SqlCommand(insertStr, con);
insert.ExecuteNonQuery();
insertStr = "insert into t3(ziduan)values('" + data.Substring(2, 1) + "')";
insert = new SqlCommand(insertStr, con);
insert.ExecuteNonQuery();
}
sr.Close();
con.Close();
MessageBox.Show("插入数据已完成!");
}
注意要加上这两个命名空间:
using System.IO;
using System.Data.SqlClient;
已赞过
已踩过<
评论
收起
你对这个回答的评价是?
展开全部
用Cfile这个类,类内有好多函数,Read,Open,Write……,够用了
已赞过
已踩过<
评论
收起
你对这个回答的评价是?
推荐律师服务:
若未解决您的问题,请您详细描述您的问题,通过百度律临进行免费专业咨询