首页 / C# / 如何使用c#将csv数据导入Oracle

如何使用c#将csv数据导入Oracle

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了如何使用c#将csv数据导入Oracle，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含6151字，纯文字阅读大概需要9分钟。

内容图文

如何使用c#将csv数据导入Oracle.其中要导入的数据的大小为3GB,行数为7512263.我设法将csv数据导入到Oracle中,但是时间大约需要1个小时.如何加快将csv数据导入oracle所需的时间.谢谢.
这是我的代码：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Diagnostics;
using System.Threading;
using System.Text.RegularExpressions;
using System.IO;
using FileHelpers;
using System.Data.OracleClient;


namespace sqlloader
{
    class Program
    {

        static void Main(string[] args)
        {
            int jum;
            int i;
            bool isFirstLine = false;
            FileHelperEngine engine = new FileHelperEngine(typeof(XL_XDR));

            //Connect To Database
            string constr = "Data Source=(DESCRIPTION=(ADDRESS_LIST="
                 + "(ADDRESS=(PROTOCOL=TCP)(HOST= pt-9a84825594af )(PORT=1521 )))"
                 + "(CONNECT_DATA=(SERVER=DEDICATED)(SERVICE_NAME=o11g)));"
                 + "User Id=xl;Password=rahasia;";
            OracleConnection con = new OracleConnection(constr);
            con.Open();



            // To Read Use:
            XL_XDR[] res = engine.ReadFile("DataOut.csv") as XL_XDR[];


            jum = CountLinesInFile("DataOut.csv");

            FileInfo f2 = new FileInfo("DataOut.csv");
            long s2 = f2.Length;
            int jmlRecord = jum - 1;

            for (i = 0; i < jum; i++)
            {
                ShowPercentProgress("Processing...", i, jum);
                Thread.Sleep(100);

                if (isFirstLine == false)
                {
                    isFirstLine = true;
                }
                else
                {
                    string sql = "INSERT INTO XL_XDR (XDR_ID, XDR_TYPE, SESSION_START_TIME, SESSION_END_TIME, SESSION_LAST_UPDATE_TIME, " +
                                 "SESSION_FLAG, VERSION, CONNECTION_ROW_COUNT, ERROR_CODE, METHOD, HOST_LEN, HOST, URL_LEN, URL, CONNECTION_START_TIME, " +
                                 "CONNECTION_LAST_UPDATE_TIME, CONNECTION_FLAG, CONNECTION_ID, TOTAL_EVENT_COUNT, TUNNEL_PAIR_ID, RESPONSIVENESS_TYPE, " +
                                 "CLIENT_PORT, PAYLOAD_TYPE, VIRTUAL_TYPE, VID_CLIENT, VID_SERVER, CLIENT_ADDR, SERVER_ADDR, CLIENT_TUNNEL_ADDR, " +
                                 "SERVER_TUNNEL_ADDR, ERROR_CODE_2, IPID, C2S_PKTS, C2S_OCTETS, S2C_PKTS, S2C_OCTETS, NUM_SUCC_TRANS, CONNECT_TIME, " +
                                 "TOTAL_RESP, TIMEOUTS, RETRIES, RAI, TCP_SYNS, TCP_SYN_ACKS, TCP_SYN_RESETS, TCP_SYN_FINS, EVENT_TYPE, FLAGS, TIME_STAMP, " +
                                 "EVENT_ID, EVENT_CODE) VALUES (" +
                                 "'" + res[i].XDR_ID + "', '" + res[i].XDR_TYPE + "', '" + res[i].SESSION_START_TIME + "', '" + res[i].SESSION_END_TIME + "', " +
                                 "'" + res[i].SESSION_LAST_UPDATE_TIME + "', '" + res[i].SESSION_FLAG + "', '" + res[i].VERSION + "', '" + res[i].CONNECTION_ROW_COUNT + "', " +
                                 "'" + res[i].ERROR_CODE + "', '" + res[i].METHOD + "', '" + res[i].HOST_LEN + "', '" + res[i].HOST + "', " +
                                 "'" + res[i].URL_LEN + "', '" + res[i].URL + "', '" + res[i].CONNECTION_START_TIME + "', '" + res[i].CONNECTION_LAST_UPDATE_TIME + "', " +
                                 "'" + res[i].CONNECTION_FLAG + "', '" + res[i].CONNECTION_ID + "', '" + res[i].TOTAL_EVENT_COUNT + "', '" + res[i].TUNNEL_PAIR_ID + "', " +
                                 "'" + res[i].RESPONSIVENESS_TYPE + "', '" + res[i].CLIENT_PORT + "', '" + res[i].PAYLOAD_TYPE + "', '" + res[i].VIRTUAL_TYPE + "', " +
                                 "'" + res[i].VID_CLIENT + "', '" + res[i].VID_SERVER + "', '" + res[i].CLIENT_ADDR + "', '" + res[i].SERVER_ADDR + "', " +
                                 "'" + res[i].CLIENT_TUNNEL_ADDR + "', '" + res[i].SERVER_TUNNEL_ADDR + "', '" + res[i].ERROR_CODE_2 + "', '" + res[i].IPID + "', " +
                                 "'" + res[i].C2S_PKTS + "', '" + res[i].C2S_OCTETS + "', '" + res[i].S2C_PKTS + "', '" + res[i].S2C_OCTETS + "', " +
                                 "'" + res[i].NUM_SUCC_TRANS + "', '" + res[i].CONNECT_TIME + "', '" + res[i].TOTAL_RESP + "', '" + res[i].TIMEOUTS + "', " +
                                 "'" + res[i].RETRIES + "', '" + res[i].RAI + "', '" + res[i].TCP_SYNS + "', '" + res[i].TCP_SYN_ACKS + "', " +
                                 "'" + res[i].TCP_SYN_RESETS + "', '" + res[i].TCP_SYN_FINS + "', '" + res[i].EVENT_TYPE + "', '" + res[i].FLAGS + "', " +
                                 "'" + res[i].TIME_STAMP + "', '" + res[i].EVENT_ID + "', '" + res[i].EVENT_CODE + "')";

                    OracleCommand command = new OracleCommand(sql, con);
                    command.ExecuteNonQuery();

                }




            }

            Console.WriteLine("Successfully Inserted");
            Console.WriteLine();
            Console.WriteLine("Number of Row Data: " + jmlRecord.ToString());
            Console.WriteLine();
            Console.WriteLine("The size of {0} is {1} bytes.", f2.Name, f2.Length);
            con.Close();




        }

        static void ShowPercentProgress(string message, int currElementIndex, int totalElementCount)
        {
            if (currElementIndex < 0 || currElementIndex >= totalElementCount)
            {
                throw new InvalidOperationException("currElement out of range");
            }
            int percent = (100 * (currElementIndex + 1)) / totalElementCount;
            Console.Write("\r{0}{1}% complete", message, percent);
            if (currElementIndex == totalElementCount - 1)
            {
                Console.WriteLine(Environment.NewLine);
            }
        }

        static int CountLinesInFile(string f)
        {
            int count = 0;
            using (StreamReader r = new StreamReader(f))
            {
                string line;
                while ((line = r.ReadLine()) != null)
                {
                    count++;
                }
            }
            return count;
        }

    }

    [DelimitedRecord(",")]
    public class XL_XDR
    {
        public string XDR_ID;
        public string XDR_TYPE;
        public string SESSION_START_TIME;
        public string SESSION_END_TIME;
        public string SESSION_LAST_UPDATE_TIME;
        public string SESSION_FLAG;
        public string VERSION;
        public string CONNECTION_ROW_COUNT;
        public string ERROR_CODE;
        public string METHOD;
        public string HOST_LEN;
        public string HOST;
        public string URL_LEN;
        public string URL;
        public string CONNECTION_START_TIME;
        public string CONNECTION_LAST_UPDATE_TIME;
        public string CONNECTION_FLAG;
        public string CONNECTION_ID;
        public string TOTAL_EVENT_COUNT;
        public string TUNNEL_PAIR_ID;
        public string RESPONSIVENESS_TYPE;
        public string CLIENT_PORT;
        public string PAYLOAD_TYPE;
        public string VIRTUAL_TYPE;
        public string VID_CLIENT;
        public string VID_SERVER;
        public string CLIENT_ADDR;
        public string SERVER_ADDR;
        public string CLIENT_TUNNEL_ADDR;
        public string SERVER_TUNNEL_ADDR;
        public string ERROR_CODE_2;
        public string IPID;
        public string C2S_PKTS;
        public string C2S_OCTETS;
        public string S2C_PKTS;
        public string S2C_OCTETS;
        public string NUM_SUCC_TRANS;
        public string CONNECT_TIME;
        public string TOTAL_RESP;
        public string TIMEOUTS;
        public string RETRIES;
        public string RAI;
        public string TCP_SYNS;
        public string TCP_SYN_ACKS;
        public string TCP_SYN_RESETS;
        public string TCP_SYN_FINS;
        public string EVENT_TYPE;
        public string FLAGS;
        public string TIME_STAMP;
        public string EVENT_ID;
        public string EVENT_CODE;


    }
}

解决方法:

我在ODB.NET中使用批量绑定方法很幸运.在此页面上搜索“ ArrayBindCount”.

http://dotnetslackers.com/articles/ado_net/BulkOperationsUsingOracleDataProviderForNETODPNET.aspx

这将允许您一次插入所有内容,而不是成千上万的小插入.您当前看到的小时数将变为几分钟.

内容总结

以上是互联网集市为您收集整理的如何使用c#将csv数据导入Oracle全部内容，希望文章能够帮你解决如何使用c#将csv数据导入Oracle所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/883268.html

来源：【匿名】

【上一篇】C#-显示每个请求的所有linq sql查询【下一篇】assemblyinfo.csC#Assembly类访问程序集信息

更多 ►

【如何使用c#将csv数据导入Oracle】教程文章相关的互联网学习教程文章

C# 用vs2008连接SQL数据库做动态水晶报表【代码】【图】

博主是个还在上大学的新手，如果有什么说错的地方请务必帮我指出来，谢谢！想要完成一个能够动态改变其中数据的水晶报表，可以通过创建一个数据的中转站来存储和输出数据的方式。借由这个中转站，我们可以通过为它动态输入数据，然后再将数据导出到水晶报表，来达到得到有动态数据的水晶报表的目的。仅在vs2008中，很多它自带的应用也可以达到中转站的作用，比如数组，数据集等。博主最近刚在学SQL所以尝试了用VS连接数据库来做水...

C#语言数据总结【图】

整数类型sbyte -128~127之间byte 0~255short(Int16) -32768~32768ushort(UInt16) 0~65535Int (Int32) -2147483648~2147483647uint(UInt32) 0~4294967295long (Int64) -2exp(31)~2exp(31)ulong(UInt64) 0~2exp(32) 浮点类型Float 32位单精度 6位精度±1.5X10exp(-45)~ ±1.5X10exp(38)Double 64位双精度 15/16位精度±5.0X10exp(-324)~ ±1.7X10exp(308)Decimal 218位高精度 28位精度±1.0X10exp(-28)~ ±7.9X10exp(...

c#和数据库技术基础之程序设计集散地-数据库

数据库，不明觉厉，今天我们就来数据库的神秘面纱1.使用数据库的必要性　　随着互联网技术的高速发展，截止到2013年我国网民的数量已接近6亿，网民数量的增长同事带动网上购物，微博，网络视频等新产业的发展。那么，随之而来的及时庞大的网络数据量。　　大量的数据正在不断产生，伴随而来的事如何安全有效的存储，检索，管理他们。对数据的有效存储，高效访问，方便共享和安全控制问题成为信息时代一个非常重要的问题。　　使用数...

【MongoDB】C#中的Mongo数据类型转换【代码】

用过Mongo的人都知道，Mongo使用的是Bson类型，有string,int,date,bool等数据类型，具体就不详述了。在使用Mongo 的C#官方驱动时会碰到一个问题，如何将Bson中的数据类型与C#中的数据类型匹配起来。以下就是我在实际项目中碰到的需要匹配的数据类型。 id比如说所有的Mongo文档里都有一个_id,如果没有标识，直接在对象类中定义一个_id属性，那么在数据读取或保存时就会报错。因此在对象类中应当如下进行定义：[BsonId] public Objec...

数据分页c#

存储过程分页的全套代码aspx页面的代码using System;using System.Collections.Generic;using System.Linq;using System.Web;using System.Web.UI;using System.Web.UI.WebControls;using System.Data;using System.Data.SqlClient;namespace AspDotNet07_AjaxCRUD.View{ public partial class WebForm1 : System.Web.UI.Page { public static int pageIndex=1; public static int pageSize=10; publ...

C# DataTable 去重复数据方法【代码】

//获取dt中Id，Value 2个字段不重复的数据 newDt = dt.DefaultView.ToTable(true, "Id","Value" ); 原文：https://www.cnblogs.com/zhang1f/p/11667053.html

C#连接ODBC数据源代码

C#连接ODBC数据源代码// Namespaces, variables, and constantsusing System;using System.Configuration;using System.Data;using System.Data.Odbc;private void CButton_Click(object sender, System.EventArgs e){ // Create the DataAdapter.#codego.net # codego.net# String sql = "SELECT ID, Name FROM Products"; OdbcDataAdapter da = new OdbcDataAdapter(sql,ConfigurationSettings.AppSettings["connection...

[C#]Thread与委托实现定时刷新数据功能【代码】【图】

用户需求：定时抓取ERP系统条码已扫描未审核单据解决办法：由于采用Timer控件会消耗系统资源，故采用线程处理。由于线程调用方法不支持控件处理模式，故采用委托方法实现。bool bStop;public DataTable dt = new DataTable();publicScanedNotChecked_Frm(){InitializeComponent();}privatevoidScanedNotChecked_Frm_Load(object sender, EventArgs e){//定义线程 Thread LogThread = new Thread(new ThreadStart(DoService)...

C# 向文件的最后中添加字节数据以及读取和删除最后的字节数据【代码】

有时候保存数据的时候不想额外的搞个配置文件了，就想着能不能直接写到现有的文件中呢，答案是可以的static void Main(string[] args) {try {Test();} catch (Exception ex) {Console.WriteLine(ex.ToString());}Console.WriteLine("end");Console.ReadKey();}static void Test() {string filePath = "E:\\test.jpg";SaveInfo(filePath, "info测试123");Console.WriteLine(GetInfo(filePath));}/// <summary>/// 向文件流中添加数据...

工业领域C# 联合MES数据上传

MES系统本质是用来实现对生产现场、质量跟踪和追溯、质量控制、生产设备的管理功能，为生产部、品质保证部、工艺等部门提供车间管理信息服务。 /// <summary> /// 创建Get方式的HTTP请求 /// </summary> /// <param name="Url">接口地址</param> /// <returns></returns> public static string Get(string Url) { try { HttpWebRequest request =...

C，C++，C#，JAVA，SQL Server，Oracle，MySQL数据类型比较

Int64:表示有符号 64 位整数，表示值介于 -2^63 ( -9,223,372,036,854,775,808) 到2^63-1(+9,223,372,036,854,775,807 )之间的整数。相当于C++的long long,C#中long，SQL Server的bigint原文：http://www.cnblogs.com/bluewhy/p/5144348.html

C#数据仓储类【代码】

https://ninesky.codeplex.com/SourceControl/latest 1/*==============================2版本：v0.13创建：2016.2.64作者：洞庭夕照5博客:http://mzwhj.cnblogs.com 6-----------------------------7修改：2016.3.48public int Delete(T entity, bool isSave)9Remove 改为Attach10-----------------------------11修改：2016.3.1712public IQueryable<T> FindPageList(int pageSize, int pageIndex, out int totalNumber, Expre...

在C#中，不安装Oracle客户端如何连接Oracle数据库【代码】【图】

本方法优点： 1、程序内集成Oracle客户端，无需用户自行进行配置本方法缺点： 2、增加程序包的体积（Oracle instant client本身有几十兆大小）下面说一下如何实现。0、首先，从Oracle网站上下载对应版本的Oracle instant client包，网址在这里 http://www.oracle.com/technetwork/database/features/instant-client/index-097480.html 由于是Windows程序，只需要下载Win32或64版本就行了。1、下载来的.zip压缩包，解压后应该有如下...

【转载】C#.NET WebApi返回各种类型(图片/json数据/字符串)，.net图片转二进制流或byte【代码】

C#.NET WebApi返回各种类型(图片/json数据/字符串)，.net图片转二进制流或byte转载：http://www.itdos.com/Mvc/20150302/0741255.htmlusing System.IO; ///<summary>/// WebApi返回图片 ///</summary>public HttpResponseMessage GetQrCode() { var imgPath = @"D:\ITdosCom\Images\itdos.jpg"; //从图片中读取byte var imgByte = File.ReadAllBytes(imgPath); //从图片中读取流 var imgStream = new MemoryStream(File...

使用C#开发数据库应用系统

使用ListView控件展示数据笔记1:ImageList控件的属性: ImageList不能独立使用,只用来为Windows窗体中的其他控件提供图像图像列表的控件的主要属性:属性 ...

C# - 技术教程分类

C# 教程 C# 简介 C# 环境 C# 程序结构 C# 基本语法 C# 数据类型 C# 类型转换 C# 变量 C# 常量 C# 运算符 C# 判断 C# 循环 C# 封装 C# 方法 C# 可空类型 C# 数组（Array） C# 字符串（String） C# 结构体（Struct） C# 枚举（Enum） C# 类（Class） C# 继承 C# 多态性 C# 运算符重载 C# 接口（Interface） C# 命名空间（Namespace） C# 预处理器指令 C# 异常处理 C# 特性（Attribute） C# 反射（Reflection） C# 属性（Property） C# 索引器（Indexer） C# 委托（Delegate） C# 事件（Event） C# 集合（Collection） C# 泛型（Generic） C# 匿名方法 C# 不安全代码 C# 多线程 c# 全部

C# - 最热教程

c#编程连接oracle数据库无法加载DLL(oc...一个适合新手C#程序员编写练习的小项目...C# 异步UDP发送接收数据 C#程序执行时间长和慢查询解决：线程并...c# aspose操作word文档 C#继承讲解以及对象的创建 jquery+ajax+C#实现无刷新操作数据库数...C#精髓 GridView72大绝技学习gridview...c# static的全部用法收集整理 js模拟实现类似c#下的hashtable的简单功...

首页 / C# / 如何使用c#将csv数据导入Oracle

如何使用c#将csv数据导入Oracle

内容导读

内容图文

内容总结

内容备注

内容手机端

【如何使用c#将csv数据导入Oracle】教程文章相关的互联网学习教程文章

C# 用vs2008连接SQL数据库做动态水晶报表【代码】【图】

C#语言数据总结【图】

c#和数据库技术基础之程序设计集散地-数据库

【MongoDB】C#中的Mongo数据类型转换【代码】

数据分页c#

C# DataTable 去重复数据方法【代码】

C#连接ODBC数据源代码

[C#]Thread与委托实现定时刷新数据功能【代码】【图】

C# 向文件的最后中添加字节数据以及读取和删除最后的字节数据【代码】

工业领域C# 联合MES数据上传

C，C++，C#，JAVA，SQL Server，Oracle，MySQL数据类型比较

C#数据仓储类【代码】

在C#中，不安装Oracle客户端如何连接Oracle数据库【代码】【图】

【转载】C#.NET WebApi返回各种类型(图片/json数据/字符串)，.net图片转二进制流或byte【代码】

使用C#开发数据库应用系统

ORACLE - 相关标签

数据 - 相关标签

C# - 技术教程分类

C# - 最新教程

C# - 最热教程