paria136
یک شنبه 22 فروردین 1395, 05:38 صبح
سلام به همگي
اين برنامه فايل csv رو ميريزه توي sql ولي مشكل اينه خط اول رو نميريزه،واقعا نميدونم مشكل از كجاست.!!!!!!!!!!!
يه موضوع ديگه هم كه لازم به راهنمايي دارم اينه كه ميخوام هر ثانيه خط آخر فايل csv با sql مقايسه بشه كه اگر يكي نبودن ادامه اطلاعات اضافه شده رو بخونه و به sql منتقل كنه
لطفا كمكم كنيد كلا مغزم هنگ كرده :گریه::گریه::گریه:
private void button1_Click(object sender, EventArgs e)
{
string ssqltable = "Log";
SqlConnection con = new SqlConnection(@"Data Source=POURALI-PA-4114;Initial Catalog=Test;Integrated Security=True");
string filepath = "D:\\alert.csv";
StreamReader sr = new StreamReader(filepath);
string line = sr.ReadLine();
string[] value = line.Split(',');
foreach (string dc in value)
{
dt.Columns.Add(new DataColumn(dc));
}
while (!sr.EndOfStream)
{
value = sr.ReadLine().Split(',');
if (value.Length == dt.Columns.Count)
{
row = dt.NewRow();
row.ItemArray = value;
dt.Rows.Add(row);
}
}
SqlBulkCopy bc = new SqlBulkCopy(con.ConnectionString, SqlBulkCopyOptions.TableLock);
bc.DestinationTableName = "Log";
bc.BatchSize = dt.Rows.Count;
con.Open();
bc.WriteToServer(dt);
bc.Close();
con.Close();
MessageBox.Show("Done!!!");
}
اين برنامه فايل csv رو ميريزه توي sql ولي مشكل اينه خط اول رو نميريزه،واقعا نميدونم مشكل از كجاست.!!!!!!!!!!!
يه موضوع ديگه هم كه لازم به راهنمايي دارم اينه كه ميخوام هر ثانيه خط آخر فايل csv با sql مقايسه بشه كه اگر يكي نبودن ادامه اطلاعات اضافه شده رو بخونه و به sql منتقل كنه
لطفا كمكم كنيد كلا مغزم هنگ كرده :گریه::گریه::گریه:
private void button1_Click(object sender, EventArgs e)
{
string ssqltable = "Log";
SqlConnection con = new SqlConnection(@"Data Source=POURALI-PA-4114;Initial Catalog=Test;Integrated Security=True");
string filepath = "D:\\alert.csv";
StreamReader sr = new StreamReader(filepath);
string line = sr.ReadLine();
string[] value = line.Split(',');
foreach (string dc in value)
{
dt.Columns.Add(new DataColumn(dc));
}
while (!sr.EndOfStream)
{
value = sr.ReadLine().Split(',');
if (value.Length == dt.Columns.Count)
{
row = dt.NewRow();
row.ItemArray = value;
dt.Rows.Add(row);
}
}
SqlBulkCopy bc = new SqlBulkCopy(con.ConnectionString, SqlBulkCopyOptions.TableLock);
bc.DestinationTableName = "Log";
bc.BatchSize = dt.Rows.Count;
con.Open();
bc.WriteToServer(dt);
bc.Close();
con.Close();
MessageBox.Show("Done!!!");
}