如何使用C#和OleDbConnection将表定义从MS Access转换为Oracle?

问题描述 投票:0回答:2

我需要将表从MS Access复制到Oracle而不使用OracleBulkCopy(使用托管数据访问)。第一步是创建表。

从下面的代码中可以看出,我现在手动转换字段,同时查询列长度。

我想使用一个语句为我转换字段,而不必手动为所有类型添加规则,因为有很多类型。或者更好的是,只提取一些我可以在Oracle中执行的DDL。这可能吗?

            private int GetLength(string accessTableName, string columnName, OleDbConnection accessConnection)
            {
                columnName = $"[{columnName}]";
                var accessCommand = new OleDbCommand($"select max(len({columnName})) from {accessTableName}", accessConnection);
                return int.Parse(accessCommand.ExecuteScalar().ToString());
            }

            private void CreateEmptyTable(DataTable schemaTable, string tableName, OracleConnection oracleConnection, string accessTableName, OleDbConnection accessConnection)
            {
                var columnSpecs = new string[schemaTable.Rows.Count];
                for (int i = 0; i < schemaTable.Rows.Count; ++i)
                {
                    var name = schemaTable.Rows[i].ItemArray[0].ToString();
                    var dataType = schemaTable.Rows[i].ItemArray[5];
                    //var length = schemaTable.Rows[i].ItemArray[2];
                    var length = GetLength(accessTableName, name.ToString(), accessConnection);

                    var precision = schemaTable.Rows[i].ItemArray[3];
                    var scale = schemaTable.Rows[i].ItemArray[4];

                    var oracleDt = "";
                    switch (dataType.ToString())
                    {
                        case "System.String":
                            oracleDt = $"nchar({length})";
                            break;
                        case "System.Int32":
                        case "System.Int16":
                            var iLng = int.Parse(length.ToString()) * 2;
                            oracleDt = $"number({iLng},0)";
                            break;
                        case "System.Double":
                        case "System.Decimal":
                            oracleDt = $"number({length},{precision})";
                            break;
                        default:
                            throw new Exception();
                    }

                    name = name.ToString().ToUpper().Replace(' ', '_');

                    columnSpecs[i] = $"{name} {oracleDt}";
                }

                var query = $"create table MDB_{tableName.ToUpper().Replace(' ', '_')} ( {string.Join(",", columnSpecs)} )";

                var oracleCommand = new OracleCommand(query, oracleConnection);
                oracleCommand.ExecuteNonQuery();
            }
c# oracle ms-access etl oracle.manageddataaccess
2个回答
1
投票

也许您尝试在基表上执行命令来代替查询。

所以尝试这样的事情:

DoCmd.TransferDatabase acExport, "ODBC Database", strCon,
           acTable, "tblHotels2", "tblHotelEXPORT", True

现在上面是来自Access,但您发布的答案是在正确的轨道上。

当我上面发送到SQL服务器时,长,钱,备忘录,文本文件都被发送出来并在sql server上创建。我想你可以使用上面的,然后执行一系列的alter table来改变类型,但那会很痛苦。

所以在痛苦的方法之前,我会尝试上面。注意:我在基表上使用了transfer命令,而不是查询。我使用“True”作为最后一个值 - 这意味着没有数据副本,只是结构。

您也可以尝试/测试不同的ORACLE odbc驱动程序。我没有测试oracle服务器,但将上面的内容发送到SQL服务器 - 它在服务器端创建数据类型非常好。


0
投票

此选项使用Interop,但结果令人失望。数字字段转换为VARCHAR2,尚未测试其他类型。请注意,它还需要DSN文件,并且它需要Oracle ODBC驱动程序。

对于可以使用它的人来说,这里是代码:

public void CreateTableDefsUsingInterop(string accessFilePath, string accessTable, string oracleUser, string oraclePassword, string oracleTable, string oracleDSNFilePath)
{
    var strConn = $"ODBC;FILEDSN={oracleDSNFilePath};UID={oracleUser};PWD={oraclePassword}";
    var sTypExprt = "ODBC Database";

    var interop = new Application();
    interop.OpenCurrentDatabase(accessFilePath);
    var db = interop.CurrentDb();
    var emptyTable = $"n{accessTable}";
    QueryDef qd;

    qd = db.CreateQueryDef("access2ora1", $"select top 1 * into [{emptyTable}] from [{accessTable}]");
    qd.Execute();

    qd = db.CreateQueryDef("access2ora2", $"delete from [{emptyTable}]");
    qd.Execute();

    interop.DoCmd.TransferDatabase(AcDataTransferType.acExport, sTypExprt, strConn, AcObjectType.acTable, emptyTable, oracleTable);

    interop.Quit(AcQuitOption.acQuitSaveNone);
}
© www.soinside.com 2019 - 2024. All rights reserved.