private void StartImport() { SqlBulkCopy bulkCopy = new SqlBulkCopy("Server=TCCLPC47;Database=aa;Trusted_Connection=True;", SqlBulkCopyOptions.TableLock); bulkCopy.DestinationTableName = "dbo.b"; bulkCopy.WriteToServer(CreateDataTableFromFile()); } private DataTable CreateDataTableFromFile() { DataTable dt = new DataTable(); DataColumn dc; DataRow dr; dc = new DataColumn(); dc.DataType = System.Type.GetType("System.int"); dc.ColumnName = "c1"; dc.Unique = false; dt.Columns.Add(dc); dc = new DataColumn(); dc.DataType = System.Type.GetType("System.int"); dc.ColumnName = "c2"; dc.Unique = false; dt.Columns.Add(dc); dc = new DataColumn(); dc.DataType = System.Type.GetType("System.int"); dc.ColumnName = "c3"; dc.Unique = false; dt.Columns.Add(dc); dc = new DataColumn(); dc.DataType = System.Type.GetType("System.int"); dc.ColumnName = "c4"; dc.Unique = false; dt.Columns.Add(dc); FileStream fileStream = new FileStream(@"d:\A.txt", FileMode.Open); StreamReader sr = new StreamReader(@"d:\\A.txt"); string input; while ((input = sr.ReadLine()) !=null) { string[] s = input.Split(new char[] { ',' }); dr = dt.NewRow(); dr["c1"] = s[0]; dr["c2"] = s[1]; dr["c3"] = s[2]; dr["c4"] = s[3]; dt.Rows.Add(dr); } sr.Close(); return dt; } }
var
This content, along with any associated source code and files, is licensed under The Code Project Open License (CPOL)