zoukankan      html  css  js  c++  java
  • c#插入数据库

     private void button1_Click(object sender, EventArgs e)
            {
                OpenFileDialog ofd = new OpenFileDialog();
                ofd.Filter = "文本文件|*.txt";
                if (ofd.ShowDialog()!=DialogResult.OK)
                {
                    return;
                }
                string filename = ofd.FileName;
                //IEnumerable<string> lines = File.ReadLines(filename,Encoding.Default);
                string[] lines = File.ReadLines(filename,Encoding.Default).ToArray();
                DateTime starttime = DateTime.Now;
                DataTable table = new DataTable();
                table.Columns.Add("start");
                table.Columns.Add("telarea");
                table.Columns.Add("teltype");
                table.Columns.Add("areanum");
                for (int i = 1; i < lines.Length; i++)
                {
                    //string line = lines.ElementAt(i);
                    string line=lines[i];
                    string[] segs = line.Split('	');
                    string StartTelNum=segs[0];
                    string TelArea = segs[1];
                    TelArea = TelArea.Trim('"');
                    string Teltype = segs[2];
                    Teltype = Teltype.Trim('"');
                    string AreaNum = segs[3];
                    AreaNum = AreaNum.Trim('"');
                    DataRow row = table.NewRow();
                    row["start"]=StartTelNum;
                    row["telarea"]=TelArea;
                    row["teltype"]=Teltype;
                    row["areanum"] = AreaNum;
                    table.Rows.Add(row);
    
                }
                using(SqlBulkCopy bulkcopy=new SqlBulkCopy(connStr))
                {
                    bulkcopy.DestinationTableName = "TelNum";
                    bulkcopy.ColumnMappings.Add("start","StartTelNum");
                    bulkcopy.ColumnMappings.Add("telarea","TelArea");
                    bulkcopy.ColumnMappings.Add("teltype","TelType");
                    bulkcopy.ColumnMappings.Add("areanum","AreaNum");
                    bulkcopy.WriteToServer(table);
                }
                TimeSpan time = DateTime.Now - starttime;
                MessageBox.Show(time.ToString());
                //using (SqlConnection conn = new SqlConnection(connStr))
                //{
                //    for (int i = 1; i < lines.Count(); i++)
                //    {
                //        string line = lines.ElementAt(i);
                //        //string line=lines[i];
                //        string[] segs = line.Split('	');
                //        string StartTelNum = segs[0];
                //        string TelArea = segs[1];
                //        TelArea = TelArea.Trim('"');
                //        string Teltype = segs[2];
                //        Teltype = Teltype.Trim('"');
                //        string AreaNum = segs[3];
                //        AreaNum = AreaNum.Trim('"');
                //        using (SqlCommand cmd=conn.CreateCommand())
                //        {
                //            cmd.CommandText = "insert into TelNum(StartTelNum,TelArea,TelType,AreaNum) values(@s,@a,@t,@u)";
                //            cmd.Parameters.Add(new SqlParameter("@s", StartTelNum));
                //            cmd.Parameters.Add(new SqlParameter("@a",TelArea));
                //            cmd.Parameters.Add(new SqlParameter("@t", Teltype));
                //            cmd.Parameters.Add(new SqlParameter("@u",AreaNum));
                //            cmd.ExecuteNonQuery();
                //        }
                //        //SqlHelper.ExecuteNonQuery("insert into TelNum(StartTelNum,TelArea,TelType,AreaNum) values(@s,@a,@t,@u)", new SqlParameter("@s", StartTelNum), new SqlParameter("@a", TelArea), new SqlParameter("@t", Teltype), new SqlParameter("@u", AreaNum));
    
                //    }
                //}
                //foreach (string line in lines)
                //{
                //    string[] segs = line.Split('	');
                //    string StartTelNum=segs[0];
                //    string TelArea=segs[1];
                //    string Teltype=segs[2];
                //    string AreaNum=segs[3];
                //    SqlHelper.ExecuteNonQuery("insert into TelNum(StartTelNum,TelArea,TelType,AreaNum) values(@s,@a,@t,@u)",new SqlParameter("@s",StartTelNum),new SqlParameter("@a",TelArea),new SqlParameter("@t",Teltype),new SqlParameter("@u",AreaNum));
    
    
                //}
                //MessageBox.Show("一共插入了"+lines.Count()+"条数据");
            }
    
  • 相关阅读:
    C# XML 文档注释
    大数据知识学习
    现在的人,买个钢铁做的车,每天擦,每周打蜡。可对自已的身体最应该保养的“车”,却从不养护
    Asp.net项目因Session阻塞导致页面打开速度变慢
    AvoidRepeatSubmit通过Javascript避免客户端重复提交请求
    Linux下Attansic L2 网卡驱动安装
    如果知道dll文件是面向32位系统还是面向64位系统的?
    整理C# 二进制,十进制,十六进制 互转
    连接Oracle时出现“System.AccessViolationException: 尝试读取或写入受保护的内存。这通常指示其他内存已损坏。”错误的问题
    [转]删除hbase表region块脚本
  • 原文地址:https://www.cnblogs.com/lushixiong/p/4558466.html
Copyright © 2011-2022 走看看