首页 > 代码库 > 大批量数据导入
大批量数据导入
using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Windows; using System.Windows.Controls; using System.Windows.Data; using System.Windows.Documents; using System.Windows.Input; using System.Windows.Media; using System.Windows.Media.Imaging; using System.Windows.Navigation; using System.Windows.Shapes; using Microsoft.Win32; using System.IO; using System.Data.SqlClient; using System.Data; using System.Configuration; namespace 批量数据导入 { /// <summary> /// MainWindow.xaml 的交互逻辑 /// </summary> public partial class MainWindow : Window { public string connStr = ConfigurationManager.ConnectionStrings["ConnStr"].ConnectionString; public MainWindow() { InitializeComponent(); } private void btnBigIData_Click(object sender, RoutedEventArgs e) { //在导入数据的时候删除数据库的所有数据 Helper.DAL.DeleteDataAll(); OpenFileDialog ofd = new OpenFileDialog(); //弹出一个对话框,让用户选要读取的文件,如果用户选中了文件 if (ofd.ShowDialog() == true) { //获取选中文件的完整路径。 string fileName = ofd.FileName; //打开这个文件,并用指定的编码一行一行的读取这个路径,读取完后关闭该文件 string[] lines = File.ReadAllLines(fileName, Encoding.Default); //在本地创建一个DataTable DataTable dt = new DataTable(); //给dt表添加四列 dt.Columns.Add("本地dt表列Section"); dt.Columns.Add("本地dt表列Area"); dt.Columns.Add("本地dt表列NumberType"); dt.Columns.Add("本地dt表列AreaCode"); //for循环完毕以后dt表中就会有非常多的行了 for (int i = 0; i < lines.Length; i++) { string[] line = lines[i].Split(new char[] { ' ' }, StringSplitOptions.RemoveEmptyEntries); string Section = line[0].Trim(); string Area = line[1].Trim(); string NumberType = line[2].Trim(); string AreaCode = line[3].Trim(); //在dt表中创建一行 DataRow row = dt.NewRow(); //给row行的字段(列)赋值 row["本地dt表列Section"] = Section; row["本地dt表列Area"] = Area; row["本地dt表列NumberType"] = NumberType; row["本地dt表列AreaCode"] = AreaCode; //将这一行加入到dt表中 dt.Rows.Add(row); } using (SqlBulkCopy bulkCopy = new SqlBulkCopy(this.connStr)) { //你要把数据批量插入数据库的哪个表中 bulkCopy.DestinationTableName = "T_Mobile"; //下面建立本地dt表字段,与数据库表之间的映射关系 //第一个参数是自己在本地建立的dt表里的列名,第二个参数是数据库中表的对应列名 bulkCopy.ColumnMappings.Add("本地dt表列Section", "Section"); bulkCopy.ColumnMappings.Add("本地dt表列Area", "Area"); bulkCopy.ColumnMappings.Add("本地dt表列NumberType", "NumberType"); bulkCopy.ColumnMappings.Add("本地dt表列AreaCode", "AreaCode"); //将dt表放入到数据库中 bulkCopy.WriteToServer(dt); MessageBox.Show("插入完毕"); } } } } }
DAL
using System; using System.Collections.Generic; using System.Linq; using System.Text; namespace Helper { public class DAL { public static void DeleteDataAll() { SqlHelper.ExecuteNonQuery("delete from T_Mobile"); } } }
SqlHelper
using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Configuration; using System.Data.SqlClient; using System.Data; using System.Reflection; namespace Helper { public class SqlHelper { /// <summary> /// 获取连接数据库字符串 /// </summary> private static string connStr=ConfigurationManager.ConnectionStrings["ConnStr"].ConnectionString; /// <summary> /// 对连接执行 Transact-SQL 语句并返回受影响的行数 /// </summary> /// <param name="sql">对数据库表进行Insert,Update和Delete语句</param> /// <param name="parameters">sql语句参数</param> /// <returns>返回值为该命令所影响的行数</returns> public static int ExecuteNonQuery(string sql ,params SqlParameter[] parameters) { using (SqlConnection conn = new SqlConnection(connStr)) { conn.Open(); using (SqlCommand cmd = conn.CreateCommand()) { cmd.CommandText = sql; cmd.Parameters.AddRange(parameters); int i= cmd.ExecuteNonQuery(); return i; } } } /// <summary> /// 执行查询,并返回查询所返回的结果集中第一行的第一列。一般用于SQL聚合函数,如:count,Max,min,avg。。 /// </summary> /// <param name="sql">要执行的sql语句</param> /// <param name="parameters">sql语句的参数</param> /// <returns>返回查询所返回的结果集中第一行的第一列。忽略其他列或行。返回的最大字符数为 2033 个字符。</returns> public static object ExecuteScalar(string sql, params SqlParameter[] parameters) { using (SqlConnection conn=new SqlConnection (connStr)) { conn.Open(); using (SqlCommand cmd = conn.CreateCommand()) { cmd.CommandText = sql; cmd.Parameters.AddRange(parameters); //ExcuteScalar()的返回值是object类型的(如果想返回int类型的数据,可先将cmd.ExecuteSalar()转化成int类型再进行返回) return cmd.ExecuteScalar(); } } } /// <summary> /// DataSet是将查询结果填充到本地内存中,这样即使与连接断开,服务器的连接断开,都不会影响数据的读取。但是它也有一个坏处,就是只有小数据量才能往里面存放,数据量大了就给你的本地内存冲爆了。电脑会卡死去。大数据量的话还得用SqlDataReader /// </summary> /// <param name="sql">要执行的sql语句</param> /// <param name="parameters">sql语句的参数</param> /// <returns>返回值是一个DataSet</returns> public static DataSet ExecuteDataSet(string sql, params SqlParameter[] parameters) { using (SqlConnection conn = new SqlConnection(connStr)) { conn.Open(); using (SqlCommand cmd = conn.CreateCommand()) { cmd.CommandText = sql; cmd.Parameters.AddRange(parameters); DataSet ds=new DataSet(); using(SqlDataAdapter adapter=new SqlDataAdapter (cmd)) { //将cmd的执行结果填充到ds里面 adapter.Fill(ds); return ds; } } } } /// <summary> /// 执行查询,并将查询的结果以DataTable的形式返回 /// </summary> /// <param name="sql">要执行的sql语句</param> /// <param name="parameters">sql语句的参数</param> /// <returns>返回值是一个DataTable</returns> public static DataTable ExecuteDataTable(string sql, params SqlParameter[] parameters) { using (SqlConnection conn = new SqlConnection(connStr)) { conn.Open(); //换一种写法,与上面的几种写法稍稍有点不同 using (SqlCommand cmd = new SqlCommand(sql ,conn)) { cmd.Parameters.AddRange(parameters); DataTable dt = new DataTable(); using (SqlDataAdapter adapter = new SqlDataAdapter(cmd)) { adapter.Fill(dt); return dt; } } } } /// <summary> /// 将查询的结果转换成一个T类型的对象 /// </summary> /// <typeparam name="T">泛型类T</typeparam> /// <param name="sql">要执行的sql语句</param> /// <param name="parameters">sql语句的参数</param> /// <returns>T类型的对象</returns> public static List<T> ExecuteClass<T>(string sql, params SqlParameter[] parameters) { List<T> list = new List<T>(); using (SqlConnection conn = new SqlConnection(connStr)) { conn.Open(); using (SqlCommand cmd = conn.CreateCommand()) { cmd.CommandText = sql; cmd.Parameters.AddRange(parameters); DataSet ds = new DataSet(); using (SqlDataAdapter adapter = new SqlDataAdapter(cmd)) { adapter.Fill(ds); } //获取ds里面的第0个表(索引从0开始) DataTable dt = ds.Tables[0]; //获取T类型的所有公有属性 PropertyInfo[] tMembers= typeof(T).GetProperties(); //遍历dt表的所有行 for(int i=0;i <dt.Rows.Count;i ++) { //创建一个泛型T类型的对象t。 T t = Activator.CreateInstance<T>(); //遍历dt表的所有列 for (int j = 0; j < dt.Columns.Count; j++) { //遍历T类型的所有公有属性 foreach (PropertyInfo tMember in tMembers) { //如果发现dt表中的列名与遍历出来的T类型属性名相同 if (dt.Columns[j].ColumnName.ToUpper().Equals(tMember.Name.ToUpper())) { //将dt.Rows[i][j]赋值给t对象的tMember成员 if (dt.Rows[i][j] != DBNull.Value) { tMember.SetValue(t, dt.Rows[i][j], null); } else { tMember.SetValue(t, null, null); } break;//;//注意这里的break是写在if语句里面的,意思就是说如果列名和属性名称相同并且已经赋值了,那么我就跳出foreach循环,进行j+1的下次循环 } } } list.Add(t); } return list; } } } /* public static object ExecuteDataReader(string sql, params SqlParameter[] paramters) { using (SqlConnection conn = new SqlConnection(connStr)) { conn.Open(); using(SqlCommand cmd=new SqlCommand(sql,conn)) { cmd.Parameters.AddRange(paramters); using (SqlDataReader dr = cmd.ExecuteReader()) { if (dr.Read()==true) { } } } } } */ /// <summary> /// 从数据库取值赋给.net类的对象属性,如果值为DBNull.Value,则将值转换成.Net认的null /// </summary> /// <param name="value"></param> /// <returns></returns> public static object FromDbValue(object value) { if (value =http://www.mamicode.com/= DBNull.Value)>
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。