当前位置： 首页 > article >正文

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

article 2025/3/9 1:56:54

目录

说明

项目

代码

下载

说明

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

项目

.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[i];
                    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[i].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;
            }
        }
    }

}
 

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[i];
                    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[i].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;
            }
        }
    }

}

下载

源码下载


http://www.kler.cn/a/574257.html

相关文章：

  • 快速启动 vue 开发环境
  • 特斯拉FSD（全自动驾驶）功能概述
  • 迷你世界脚本文字板接口：Graphics
  • centos7服务器 Java和Hadoop安装教程，用VMware和finalshell
  • 【C++教程】C++中的基本数据类型
  • 【每日学点HarmonyOS Next知识】Web上传文件、监听上下左右区域连续点击、折叠悬停、字符串相关、播放沙盒视频
  • VsCode/Cursor workbench.desktop.main.js 的入口
  • VS2019,VCPKG - 为VS2019添加VCPKG
  • 【启发式算法】Dijkstra算法详细介绍（Python）
  • 高频 SQL 50 题（基础版）| 高级字符串函数 / 正则表达式 / 子句：1667. 修复表中的名字
  • Jenkins工具配置与运用指南：从零到持续交付
  • 网络安全 三高三弱治理
  • 【进程和线程】（面试高频考点）
  • HTML第四节
  • Android Studio快速配置国内镜像源和HTTP代理
  • python基础课程整理--元组的基础
  • 分类预测 | Matlab实现PSO-BP-Adaboost基于粒子群算法优化BP神经网络结合Adaboost思想的分类预测模型
  • 同一个网段的IP可以自由访问吗?不同网段的IP必须通过公网IP访问吗?
  • 【鸿蒙操作系统】- 1：实习阶段的一些总结
  • 【项目】视频点播