Oracle数据导入导出小工具（主要用于导入导出小批量含大字段的数据） ...

目次
分析
项目
代码
下载

---

分析

各种缘故原由要导入导出几张表的数据，表中有几个大字段，各种不方便……，就写了这个小工具
项目

.net framework 4.8+Oracle.ManagedDataAccess

代码

using Oracle.ManagedDataAccess.Client;
using System;
using System.Collections.Generic;
using System.Data;
using System.Diagnostics;
using System.Globalization;
using System.IO;
using System.Text.Json;
using System.Threading;
using System.Windows.Forms;
namespace OracleLargeObjectHelper
{
    public partial class frmMain : Form
    {
        public frmMain()
        {
            InitializeComponent();
        }
        string connectionString = "";
        OracleLargeObjectHandler oracleLargeObjectHandler = null;
        /// <summary>
        /// 导出
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void btnExportTable_Click(object sender, EventArgs e)
        {
            if (String.IsNullOrEmpty(txtExportTableName.Text))
            {
                MessageBox.Show("请输入导出表名！");
                txtExportTableName.Focus();
                return;
            }
            try
            {
                btnExportTable.Enabled = false;
                if (oracleLargeObjectHandler == null)
                {
                    MessageBox.Show("请先测试连接！");
                    return;
                }
                int rowCount = 0;
                Stopwatch sw = new Stopwatch();
                sw.Start();
                oracleLargeObjectHandler.ExportTable(txtExportTableName.Text, txtExportTableName.Text + ".json", out rowCount);
                sw.Stop();
                MessageBox.Show($"导出成功，共计[{rowCount}]条记录，耗时[{sw.ElapsedMilliseconds / 1000.0}秒]");
            }
            catch (Exception ex)
            {
                MessageBox.Show("导出失败：" + ex.Message);
            }
            finally
            {
                btnExportTable.Enabled = true;
            }
        }
        /// <summary>
        /// 导入
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void btnImportTable_Click(object sender, EventArgs e)
        {
            //txtImportTableName
            if (String.IsNullOrEmpty(txtImportTableName.Text))
            {
                MessageBox.Show("请输入导入表名！");
                txtExportTableName.Focus();
                return;
            }
            //txtinputFile
            if (String.IsNullOrEmpty(txtinputFile.Text))
            {
                MessageBox.Show("请选择数据文件！");
                txtinputFile.Focus();
                return;
            }
            try
            {
                btnImportTable.Enabled = false;
                if (oracleLargeObjectHandler == null)
                {
                    MessageBox.Show("请先测试连接！");
                    return;
                }
                int rowCount = 0;
                Stopwatch sw = new Stopwatch();
                sw.Start();
                oracleLargeObjectHandler.ImportTable(txtinputFile.Text, txtImportTableName.Text, out rowCount);
                MessageBox.Show($"导入成功，共计[{rowCount}]条记录，耗时[{sw.ElapsedMilliseconds/1000.0}秒]");
            }
            catch (Exception ex)
            {
                MessageBox.Show("导入失败：" + ex.Message);
            }
            finally
            {
                btnImportTable.Enabled = true;
            }
        }
        private void frmMain_Load(object sender, EventArgs e)
        {
        }
        /// <summary>
        /// 测试链接
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void btnTestConn_Click(object sender, EventArgs e)
        {
            if (String.IsNullOrEmpty(txtConnStr.Text))
            {
                MessageBox.Show("请输入连接字符串！");
                txtConnStr.Focus();
                return;
            }
            connectionString = txtConnStr.Text;
            try
            {
                btnTestConn.Enabled = false;
                var conn = new OracleConnection(connectionString);
                conn.Open();
                MessageBox.Show("连接成功！");
                oracleLargeObjectHandler = new OracleLargeObjectHandler(connectionString);
            }
            catch (Exception ex)
            {
                MessageBox.Show("连接失败:" + ex.Message);
            }
            finally
            {
                btnTestConn.Enabled = true;
            }
        }
        /// <summary>
        /// 选择导入文件
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void btnSelectImportFile_Click(object sender, EventArgs e)
        {
            OpenFileDialog ofd = new OpenFileDialog();
            ofd.Title = $"选择导入文件";
            ofd.Filter = "json文件| *.json;";
            ofd.ValidateNames = true;     //文件有用性验证ValidateNames，验证用户输入是否是一个有用的Windows文件名
            ofd.CheckFileExists = true;  //验证路径有用性
            ofd.CheckPathExists = true; //验证文件有用性
            ofd.InitialDirectory = AppDomain.CurrentDomain.BaseDirectory;
            if (ofd.ShowDialog() == DialogResult.OK)
            {
                string file = ofd.FileName;//文件的完备路径
                txtinputFile.Text = file;
                //文件路径
                var path = System.IO.Path.GetFullPath(file);
                //文件名
                string name = System.IO.Path.GetFileNameWithoutExtension(path);
                txtImportTableName.Text = name;
            }
        }
    }
    public class OracleLargeObjectHandler
    {
        private readonly string _connectionString;
        public OracleLargeObjectHandler(string connectionString)
        {
            _connectionString = connectionString;
        }
        public void ExportTable(string tableName, string outputFilePath, out int rowCount)
        {
            var conn = new OracleConnection(_connectionString);
            conn.Open();
            rowCount = 0;
            // 获取表结构信息
            var columns = GetTableColumns(conn, tableName);
            var cmd = conn.CreateCommand();
            cmd.CommandText = $"SELECT * FROM {tableName}";
            var reader = cmd.ExecuteReader(CommandBehavior.SequentialAccess); // 紧张：次序访问大字段
            var fs = new FileStream(outputFilePath, FileMode.Create);
            var writer = new Utf8JsonWriter(fs);
            writer.WriteStartArray();
            while (reader.Read())
            {
                rowCount++;
                writer.WriteStartObject();
                for (int i = 0; i < reader.FieldCount; i++)
                {
                    var column = columns;
                    writer.WritePropertyName(column.Name);
                    if (reader.IsDBNull(i))
                    {
                        writer.WriteNullValue();
                    }
                    else
                    {
                        switch (column.DataType)
                        {
                            case "BLOB":
                                var buffer = reader.GetOracleBlob(i).Value;
                                writer.WriteBase64StringValue(buffer);
                                break;
                            case "CLOB":
                                writer.WriteStringValue(reader.GetOracleClob(i).Value);
                                break;
                            case "DATE":
                                writer.WriteStringValue(reader.GetDateTime(i).ToString("yyyy-MM-dd HH:mm:ss"));
                                break;
                            case "TIMESTAMP":
                                writer.WriteStringValue(reader.GetDateTime(i).ToString("yyyy-MM-dd HH:mm:ss.fff"));
                                break;
                            case "NUMBER":
                                var value = reader.GetOracleDecimal(i);
                                writer.WriteNumberValue(value.ToDouble());
                                break;
                            default:
                                writer.WriteStringValue(reader.ToString());
                                break;
                        }
                    }
                }
                writer.WriteEndObject();
            }
            writer.WriteEndArray();
            // 显式刷新缓冲区
            writer.Flush();
            writer.Dispose();
            fs.Dispose();
            reader.Dispose();
            cmd.Dispose();
            conn.Dispose();
        }
        public void ImportTable(string inputFilePath, string tableName, out int rowCount, int batchSize = 1000)
        {
            if (!File.Exists(inputFilePath))
            {
                throw new FileNotFoundException($"导出文件 {inputFilePath} 不存在");
            }
            var fileInfo = new FileInfo(inputFilePath);
            if (fileInfo.Length == 0)
            {
                throw new InvalidDataException("导出文件为空，请检查导出操纵是否成功");
            }
            // 添加JSON格式预验证
            try
            {
                var jsonDoc = JsonDocument.Parse(File.ReadAllBytes(inputFilePath));
                jsonDoc.Dispose();
            }
            catch (JsonException ex)
            {
                throw new InvalidDataException("JSON文件格式错误", ex);
            }
            var conn = new OracleConnection(_connectionString);
            conn.Open();
            var columns = GetTableColumns(conn, tableName);
            var insertColumns = string.Join(", ", columns.ConvertAll(c => c.Name));
            var parameters = string.Join(", ", columns.ConvertAll(c => $":{c.Name}"));
            var transaction = conn.BeginTransaction();
            var cmd = conn.CreateCommand();
            cmd.CommandText = $"INSERT INTO {tableName} ({insertColumns}) VALUES ({parameters})";
            cmd.BindByName = true;
            var records = JsonSerializer.Deserialize<List<Dictionary<string, JsonElement>>>(File.ReadAllBytes(inputFilePath));
            rowCount = 0;
            foreach (var record in records)
            {
                cmd.Parameters.Clear();
                foreach (var column in columns)
                {
                    var jsonElement = record[column.Name];
                    if (jsonElement.ValueKind == JsonValueKind.Null)
                    {
                        cmd.Parameters.Add(new OracleParameter(column.Name, DBNull.Value));
                        continue;
                    }
                    switch (column.DataType)
                    {
                        case "BLOB":
                            var blobParam = new OracleParameter(column.Name, OracleDbType.Blob);
                            blobParam.Value = jsonElement.GetBytesFromBase64();
                            cmd.Parameters.Add(blobParam);
                            break;
                        case "CLOB":
                            var clobValue = jsonElement.GetString();
                            var clobParam = new OracleParameter(column.Name, OracleDbType.Clob)
                            {
                                Value = clobValue
                            };
                            cmd.Parameters.Add(clobParam);
                            break;
                        case "DATE":
                            var dateValue = DateTime.ParseExact(
                                jsonElement.GetString(),
                                "yyyy-MM-dd HH:mm:ss", // 与导特别式保持一致
                                CultureInfo.InvariantCulture
                            );
                            var dateParam = new OracleParameter(column.Name, OracleDbType.Date)
                            {
                                Value = dateValue
                            };
                            cmd.Parameters.Add(dateParam);
                            break;
                        case "TIMESTAMP":
                            var timestampValue = DateTime.ParseExact(
                                jsonElement.GetString(),
                                "yyyy-MM-dd HH:mm:ss.fff",// 与导特别式保持一致
                                CultureInfo.InvariantCulture
                            );
                            var timestampParam = new OracleParameter(column.Name, OracleDbType.TimeStamp)
                            {
                                Value = timestampValue
                            };
                            cmd.Parameters.Add(timestampParam);
                            break;
                        case "NUMBER":
                            cmd.Parameters.Add(new OracleParameter(column.Name,
                                OracleDbType.Decimal,
                                jsonElement.GetDecimal(),
                                ParameterDirection.Input));
                            break;
                        case "VARCHAR2":
                        case "CHAR":
                            var strValue = jsonElement.GetString();
                            if (strValue.Length > column.Length)
                            {
                                throw new InvalidOperationException(
                                    $"字段 {column.Name} 值长度超过限制({column.Length})");
                            }
                            cmd.Parameters.Add(new OracleParameter(column.Name, strValue));
                            break;
                        default:
                            cmd.Parameters.Add(new OracleParameter(column.Name, jsonElement.GetString()));
                            break;
                    }
                }
                cmd.ExecuteNonQuery();
                if (++rowCount % batchSize == 0)
                {
                    transaction.Commit();
                    transaction.Dispose();
                    transaction = conn.BeginTransaction();
                }
            }
            transaction.Commit();
            transaction.Dispose();
            cmd.Dispose();
            conn.Close();
        }
        private List<TableColumn> GetTableColumns(OracleConnection conn, string tableName)
        {
            var columns = new List<TableColumn>();
            var cmd = conn.CreateCommand();
            cmd.CommandText = @"
            SELECT 
                column_name, 
                data_type,
                data_precision,
                data_scale,
                data_length
            FROM all_tab_cols 
            WHERE table_name = :tableName 
            ORDER BY column_id";
            cmd.Parameters.Add(new OracleParameter("tableName", tableName.ToUpper()));
            var reader = cmd.ExecuteReader();
            while (reader.Read())
            {
                columns.Add(new TableColumn(
                    reader.GetString(0),
                    reader.GetString(1),
                    reader.IsDBNull(2) ? (int?)null : reader.GetInt32(2),
                    reader.IsDBNull(3) ? (int?)null : reader.GetInt32(3),
                    reader.GetInt32(4)
                ));
            }
            reader.Dispose();
            cmd.Dispose();
            return columns;
        }
        private class TableColumn
        {
            public string Name { get; }
            public string DataType { get; }
            public int? Precision { get; }
            public int? Scale { get; }
            public int Length { get; }
            public TableColumn(string name, string dataType, int? precision, int? scale, int length)
            {
                Name = name;
                DataType = dataType.ToUpper();
                Precision = precision;
                Scale = scale;
                Length = length;
            }
        }
    }
}
 

1. using Oracle.ManagedDataAccess.Client;
2. using System;
3. using System.Collections.Generic;
4. using System.Data;
5. using System.Diagnostics;
6. using System.Globalization;
7. using System.IO;
8. using System.Text.Json;
9. using System.Threading;
10. using System.Windows.Forms;
12. namespace OracleLargeObjectHelper
13. {
14.     public partial class frmMain : Form
15.     {
16.         public frmMain()
17.         {
18.             InitializeComponent();
19.         }
21.         string connectionString = "";
22.         OracleLargeObjectHandler oracleLargeObjectHandler = null;
24.         /// <summary>
25.         /// 导出
26.         /// </summary>
27.         /// <param name="sender"></param>
28.         /// <param name="e"></param>
29.         private void btnExportTable_Click(object sender, EventArgs e)
30.         {
31.             if (String.IsNullOrEmpty(txtExportTableName.Text))
32.             {
33.                 MessageBox.Show("请输入导出表名！");
34.                 txtExportTableName.Focus();
35.                 return;
36.             }
38.             try
39.             {
40.                 btnExportTable.Enabled = false;
42.                 if (oracleLargeObjectHandler == null)
43.                 {
44.                     MessageBox.Show("请先测试连接！");
45.                     return;
46.                 }
47.                 int rowCount = 0;
48.                 Stopwatch sw = new Stopwatch();
49.                 sw.Start();
50.                 oracleLargeObjectHandler.ExportTable(txtExportTableName.Text, txtExportTableName.Text + ".json", out rowCount);
51.                 sw.Stop();
52.                 MessageBox.Show($"导出成功，共计[{rowCount}]条记录，耗时[{sw.ElapsedMilliseconds / 1000.0}秒]");
54.             }
55.             catch (Exception ex)
56.             {
57.                 MessageBox.Show("导出失败：" + ex.Message);
58.             }
59.             finally
60.             {
61.                 btnExportTable.Enabled = true;
62.             }
63.         }
65.         /// <summary>
66.         /// 导入
67.         /// </summary>
68.         /// <param name="sender"></param>
69.         /// <param name="e"></param>
70.         private void btnImportTable_Click(object sender, EventArgs e)
71.         {
72.             //txtImportTableName
73.             if (String.IsNullOrEmpty(txtImportTableName.Text))
74.             {
75.                 MessageBox.Show("请输入导入表名！");
76.                 txtExportTableName.Focus();
77.                 return;
78.             }
80.             //txtinputFile
81.             if (String.IsNullOrEmpty(txtinputFile.Text))
82.             {
83.                 MessageBox.Show("请选择数据文件！");
84.                 txtinputFile.Focus();
85.                 return;
86.             }
88.             try
89.             {
90.                 btnImportTable.Enabled = false;
91.                 if (oracleLargeObjectHandler == null)
92.                 {
93.                     MessageBox.Show("请先测试连接！");
94.                     return;
95.                 }
96.                 int rowCount = 0;
97.                 Stopwatch sw = new Stopwatch();
98.                 sw.Start();
99.                 oracleLargeObjectHandler.ImportTable(txtinputFile.Text, txtImportTableName.Text, out rowCount);
100.                 MessageBox.Show($"导入成功，共计[{rowCount}]条记录，耗时[{sw.ElapsedMilliseconds/1000.0}秒]");
101.             }
102.             catch (Exception ex)
103.             {
104.                 MessageBox.Show("导入失败：" + ex.Message);
105.             }
106.             finally
107.             {
108.                 btnImportTable.Enabled = true;
109.             }
110.         }
112.         private void frmMain_Load(object sender, EventArgs e)
113.         {
115.         }
117.         /// <summary>
118.         /// 测试链接
119.         /// </summary>
120.         /// <param name="sender"></param>
121.         /// <param name="e"></param>
122.         private void btnTestConn_Click(object sender, EventArgs e)
123.         {
124.             if (String.IsNullOrEmpty(txtConnStr.Text))
125.             {
126.                 MessageBox.Show("请输入连接字符串！");
127.                 txtConnStr.Focus();
128.                 return;
129.             }
130.             connectionString = txtConnStr.Text;
132.             try
133.             {
134.                 btnTestConn.Enabled = false;
135.                 var conn = new OracleConnection(connectionString);
136.                 conn.Open();
137.                 MessageBox.Show("连接成功！");
138.                 oracleLargeObjectHandler = new OracleLargeObjectHandler(connectionString);
139.             }
140.             catch (Exception ex)
141.             {
142.                 MessageBox.Show("连接失败:" + ex.Message);
143.             }
144.             finally
145.             {
146.                 btnTestConn.Enabled = true;
147.             }
149.         }
151.         /// <summary>
152.         /// 选择导入文件
153.         /// </summary>
154.         /// <param name="sender"></param>
155.         /// <param name="e"></param>
156.         private void btnSelectImportFile_Click(object sender, EventArgs e)
157.         {
158.             OpenFileDialog ofd = new OpenFileDialog();
159.             ofd.Title = $"选择导入文件";
160.             ofd.Filter = "json文件| *.json;";
161.             ofd.ValidateNames = true;     //文件有效性验证ValidateNames，验证用户输入是否是一个有效的Windows文件名
162.             ofd.CheckFileExists = true;  //验证路径有效性
163.             ofd.CheckPathExists = true; //验证文件有效性
164.             ofd.InitialDirectory = AppDomain.CurrentDomain.BaseDirectory;
165.             if (ofd.ShowDialog() == DialogResult.OK)
166.             {
167.                 string file = ofd.FileName;//文件的完整路径
168.                 txtinputFile.Text = file;
169.                 //文件路径
170.                 var path = System.IO.Path.GetFullPath(file);
171.                 //文件名
172.                 string name = System.IO.Path.GetFileNameWithoutExtension(path);
173.                 txtImportTableName.Text = name;
174.             }
175.         }
176.     }
178.     public class OracleLargeObjectHandler
179.     {
180.         private readonly string _connectionString;
182.         public OracleLargeObjectHandler(string connectionString)
183.         {
184.             _connectionString = connectionString;
185.         }
187.         public void ExportTable(string tableName, string outputFilePath, out int rowCount)
188.         {
189.             var conn = new OracleConnection(_connectionString);
190.             conn.Open();
191.             rowCount = 0;
192.             // 获取表结构信息
193.             var columns = GetTableColumns(conn, tableName);
195.             var cmd = conn.CreateCommand();
196.             cmd.CommandText = $"SELECT * FROM {tableName}";
198.             var reader = cmd.ExecuteReader(CommandBehavior.SequentialAccess); // 重要：顺序访问大字段
199.             var fs = new FileStream(outputFilePath, FileMode.Create);
200.             var writer = new Utf8JsonWriter(fs);
202.             writer.WriteStartArray();
204.             while (reader.Read())
205.             {
206.                 rowCount++;
207.                 writer.WriteStartObject();
209.                 for (int i = 0; i < reader.FieldCount; i++)
210.                 {
211.                     var column = columns[i];
212.                     writer.WritePropertyName(column.Name);
214.                     if (reader.IsDBNull(i))
215.                     {
216.                         writer.WriteNullValue();
217.                     }
218.                     else
219.                     {
220.                         switch (column.DataType)
221.                         {
222.                             case "BLOB":
223.                                 var buffer = reader.GetOracleBlob(i).Value;
224.                                 writer.WriteBase64StringValue(buffer);
225.                                 break;
226.                             case "CLOB":
227.                                 writer.WriteStringValue(reader.GetOracleClob(i).Value);
228.                                 break;
229.                             case "DATE":
230.                                 writer.WriteStringValue(reader.GetDateTime(i).ToString("yyyy-MM-dd HH:mm:ss"));
231.                                 break;
232.                             case "TIMESTAMP":
233.                                 writer.WriteStringValue(reader.GetDateTime(i).ToString("yyyy-MM-dd HH:mm:ss.fff"));
234.                                 break;
235.                             case "NUMBER":
236.                                 var value = reader.GetOracleDecimal(i);
237.                                 writer.WriteNumberValue(value.ToDouble());
238.                                 break;
239.                             default:
240.                                 writer.WriteStringValue(reader[i].ToString());
241.                                 break;
242.                         }
243.                     }
244.                 }
246.                 writer.WriteEndObject();
247.             }
249.             writer.WriteEndArray();
251.             // 显式刷新缓冲区
252.             writer.Flush();
254.             writer.Dispose();
255.             fs.Dispose();
256.             reader.Dispose();
257.             cmd.Dispose();
258.             conn.Dispose();
259.         }
261.         public void ImportTable(string inputFilePath, string tableName, out int rowCount, int batchSize = 1000)
262.         {
263.             if (!File.Exists(inputFilePath))
264.             {
265.                 throw new FileNotFoundException($"导出文件 {inputFilePath} 不存在");
266.             }
268.             var fileInfo = new FileInfo(inputFilePath);
269.             if (fileInfo.Length == 0)
270.             {
271.                 throw new InvalidDataException("导出文件为空，请检查导出操作是否成功");
272.             }
274.             // 添加JSON格式预验证
275.             try
276.             {
277.                 var jsonDoc = JsonDocument.Parse(File.ReadAllBytes(inputFilePath));
278.                 jsonDoc.Dispose();
279.             }
280.             catch (JsonException ex)
281.             {
282.                 throw new InvalidDataException("JSON文件格式错误", ex);
283.             }
285.             var conn = new OracleConnection(_connectionString);
286.             conn.Open();
288.             var columns = GetTableColumns(conn, tableName);
289.             var insertColumns = string.Join(", ", columns.ConvertAll(c => c.Name));
290.             var parameters = string.Join(", ", columns.ConvertAll(c => $":{c.Name}"));
292.             var transaction = conn.BeginTransaction();
293.             var cmd = conn.CreateCommand();
294.             cmd.CommandText = $"INSERT INTO {tableName} ({insertColumns}) VALUES ({parameters})";
295.             cmd.BindByName = true;
297.             var records = JsonSerializer.Deserialize<List<Dictionary<string, JsonElement>>>(File.ReadAllBytes(inputFilePath));
298.             rowCount = 0;
300.             foreach (var record in records)
301.             {
302.                 cmd.Parameters.Clear();
304.                 foreach (var column in columns)
305.                 {
306.                     var jsonElement = record[column.Name];
308.                     if (jsonElement.ValueKind == JsonValueKind.Null)
309.                     {
310.                         cmd.Parameters.Add(new OracleParameter(column.Name, DBNull.Value));
311.                         continue;
312.                     }
314.                     switch (column.DataType)
315.                     {
316.                         case "BLOB":
317.                             var blobParam = new OracleParameter(column.Name, OracleDbType.Blob);
318.                             blobParam.Value = jsonElement.GetBytesFromBase64();
319.                             cmd.Parameters.Add(blobParam);
320.                             break;
321.                         case "CLOB":
322.                             var clobValue = jsonElement.GetString();
323.                             var clobParam = new OracleParameter(column.Name, OracleDbType.Clob)
324.                             {
325.                                 Value = clobValue
326.                             };
327.                             cmd.Parameters.Add(clobParam);
328.                             break;
329.                         case "DATE":
330.                             var dateValue = DateTime.ParseExact(
331.                                 jsonElement.GetString(),
332.                                 "yyyy-MM-dd HH:mm:ss", // 与导出格式保持一致
333.                                 CultureInfo.InvariantCulture
334.                             );
335.                             var dateParam = new OracleParameter(column.Name, OracleDbType.Date)
336.                             {
337.                                 Value = dateValue
338.                             };
339.                             cmd.Parameters.Add(dateParam);
340.                             break;
342.                         case "TIMESTAMP":
343.                             var timestampValue = DateTime.ParseExact(
344.                                 jsonElement.GetString(),
345.                                 "yyyy-MM-dd HH:mm:ss.fff",// 与导出格式保持一致
346.                                 CultureInfo.InvariantCulture
347.                             );
348.                             var timestampParam = new OracleParameter(column.Name, OracleDbType.TimeStamp)
349.                             {
350.                                 Value = timestampValue
351.                             };
352.                             cmd.Parameters.Add(timestampParam);
353.                             break;
355.                         case "NUMBER":
356.                             cmd.Parameters.Add(new OracleParameter(column.Name,
357.                                 OracleDbType.Decimal,
358.                                 jsonElement.GetDecimal(),
359.                                 ParameterDirection.Input));
360.                             break;
361.                         case "VARCHAR2":
362.                         case "CHAR":
363.                             var strValue = jsonElement.GetString();
364.                             if (strValue.Length > column.Length)
365.                             {
366.                                 throw new InvalidOperationException(
367.                                     $"字段 {column.Name} 值长度超过限制({column.Length})");
368.                             }
369.                             cmd.Parameters.Add(new OracleParameter(column.Name, strValue));
370.                             break;
371.                         default:
372.                             cmd.Parameters.Add(new OracleParameter(column.Name, jsonElement.GetString()));
373.                             break;
374.                     }
375.                 }
377.                 cmd.ExecuteNonQuery();
379.                 if (++rowCount % batchSize == 0)
380.                 {
381.                     transaction.Commit();
382.                     transaction.Dispose();
383.                     transaction = conn.BeginTransaction();
384.                 }
385.             }
387.             transaction.Commit();
389.             transaction.Dispose();
390.             cmd.Dispose();
391.             conn.Close();
392.         }
394.         private List<TableColumn> GetTableColumns(OracleConnection conn, string tableName)
395.         {
396.             var columns = new List<TableColumn>();
398.             var cmd = conn.CreateCommand();
399.             cmd.CommandText = @"
400.             SELECT
401.                 column_name,
402.                 data_type,
403.                 data_precision,
404.                 data_scale,
405.                 data_length
406.             FROM all_tab_cols
407.             WHERE table_name = :tableName
408.             ORDER BY column_id";
410.             cmd.Parameters.Add(new OracleParameter("tableName", tableName.ToUpper()));
412.             var reader = cmd.ExecuteReader();
413.             while (reader.Read())
414.             {
415.                 columns.Add(new TableColumn(
416.                     reader.GetString(0),
417.                     reader.GetString(1),
418.                     reader.IsDBNull(2) ? (int?)null : reader.GetInt32(2),
419.                     reader.IsDBNull(3) ? (int?)null : reader.GetInt32(3),
420.                     reader.GetInt32(4)
421.                 ));
422.             }
424.             reader.Dispose();
425.             cmd.Dispose();
427.             return columns;
428.         }
430.         private class TableColumn
431.         {
432.             public string Name { get; }
433.             public string DataType { get; }
434.             public int? Precision { get; }
435.             public int? Scale { get; }
436.             public int Length { get; }
438.             public TableColumn(string name, string dataType, int? precision, int? scale, int length)
439.             {
440.                 Name = name;
441.                 DataType = dataType.ToUpper();
442.                 Precision = precision;
443.                 Scale = scale;
444.                 Length = length;
445.             }
446.         }
447.     }
449. }

复制代码

下载

源码下载

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。