无类型 CRUD无法同步表结构

[lostluna1]

public dynamic SyncData(ConnectionInfo sourceInfo, ConnectionInfo targetInfo, string sql)
{
    try
    {
        // 建立源数据库连接
        var sourceConnectionString = BuildConnectionString(sourceInfo);
        var sourceDataType = GetDataType(sourceInfo.DatabaseType);
        var sourceFsql = new FreeSqlBuilder()
            .UseConnectionString(sourceDataType, sourceConnectionString)
            .Build();

        // 建立目标数据库连接
        var targetConnectionString = BuildConnectionString(targetInfo);
        var targetDataType = GetDataType(targetInfo.DatabaseType);
        var targetFsql = new FreeSqlBuilder()
            .UseConnectionString(targetDataType, targetConnectionString)
            .Build();

        // 查询源数据库中的数据
        var sourceData = sourceFsql.Ado.Query<Dictionary<string, object>>(sql);

        // 获取源表结构
        var sourceTable = sourceFsql.DbFirst.GetTableByName("PRODUCTBASE");

        // 记录源表主键信息
        _logger.LogInformation($"源表主键: {string.Join(", ", sourceTable.Primarys.Select(p => p.Name))}");

        // 检查目标数据库中是否存在目标表
        var targetTable = targetFsql.DbFirst.GetTableByName("PRODUCTBASE");
        var ctx = new ZeroDbContext(targetFsql, new TableDescriptor[] { });
        if (targetTable == null)
        {
            // 如果目标表不存在，则创建目标表
            var jsonSettings = new JsonSerializerSettings
            {
                ReferenceLoopHandling = ReferenceLoopHandling.Ignore
            };
            var json = JsonConvert.SerializeObject(new[] { sourceTable }, jsonSettings);
            _logger.LogInformation($"序列化后的源表结构: {json}");
            ctx = new ZeroDbContext(targetFsql, JsonConvert.DeserializeObject<TableDescriptor[]>(json));
            _logger.LogInformation("开始同步表结构...");
            ctx.SyncTableStructure("PRODUCTBASE");
            _logger.LogInformation("表结构同步完成。");
        }
        else
        {
            // 如果目标表存在，确保表结构同步
            _logger.LogInformation("开始同步表结构...");
            ctx.SyncTableStructure("PRODUCTBASE");
            _logger.LogInformation("表结构同步完成。");
        }


        // 将数据插入到目标表中
        foreach (var item in sourceData)
        {
            ctx.Insert(item);
        }

        return "数据同步完成";
    }
    catch (Exception ex)
    {
        _logger.LogError(ex, "数据同步过程中发生错误");
        throw;
    }
}

以下是json:

[
  {
    "Id": "PRODUCTBASE",
    "Schema": "",
    "Name": "PRODUCTBASE",
    "Comment": "",
    "Type": 0,
    "Columns": [
      {
        "Name": "PRODUCTBASEID",
        "CsType": "System.String, System.Private.CoreLib, Version=8.0.0.0, Culture=neutral, PublicKeyToken=7cec85d7bea7798e",
        "DbType": 104,
        "DbTypeText": "CHAR",
        "DbTypeTextFull": "CHAR(16 BYTE)",
        "MaxLength": 16,
        "IsPrimary": true,
        "IsIdentity": false,
        "IsNullable": false,
        "Coment": "",
        "Comment": "",
        "DefaultValue": "",
        "Position": 5
      },
      {
        "Name": "CDOTYPEID",
        "CsType": "System.UInt32, System.Private.CoreLib, Version=8.0.0.0, Culture=neutral, PublicKeyToken=7cec85d7bea7798e",
        "DbType": 107,
        "DbTypeText": "NUMBER",
        "DbTypeTextFull": "NUMBER(10)",
        "MaxLength": 10,
        "IsPrimary": false,
        "IsIdentity": false,
        "IsNullable": true,
        "Coment": "",
        "Comment": "",
        "DefaultValue": "",
        "Position": 1
      },
      {
        "Name": "CHANGECOUNT",
        "CsType": "System.UInt32, System.Private.CoreLib, Version=8.0.0.0, Culture=neutral, PublicKeyToken=7cec85d7bea7798e",
        "DbType": 107,
        "DbTypeText": "NUMBER",
        "DbTypeTextFull": "NUMBER(10)",
        "MaxLength": 10,
        "IsPrimary": false,
        "IsIdentity": false,
        "IsNullable": true,
        "Coment": "",
        "Comment": "",
        "DefaultValue": "",
        "Position": 2
      },
      {
        "Name": "ICONID",
        "CsType": "System.UInt32, System.Private.CoreLib, Version=8.0.0.0, Culture=neutral, PublicKeyToken=7cec85d7bea7798e",
        "DbType": 107,
        "DbTypeText": "NUMBER",
        "DbTypeTextFull": "NUMBER(10)",
        "MaxLength": 10,
        "IsPrimary": false,
        "IsIdentity": false,
        "IsNullable": true,
        "Coment": "",
        "Comment": "",
        "DefaultValue": "",
        "Position": 3
      },
      {
        "Name": "OBJECTCATEGORY",
        "CsType": "System.String, System.Private.CoreLib, Version=8.0.0.0, Culture=neutral, PublicKeyToken=7cec85d7bea7798e",
        "DbType": 126,
        "DbTypeText": "VARCHAR2",
        "DbTypeTextFull": "VARCHAR2(40 BYTE)",
        "MaxLength": 40,
        "IsPrimary": false,
        "IsIdentity": false,
        "IsNullable": true,
        "Coment": "",
        "Comment": "",
        "DefaultValue": "",
        "Position": 4
      }
    ],
    "Identitys": [],
    "Primarys": [
      {
        "Name": "PRODUCTBASEID",
        "CsType": "System.String, System.Private.CoreLib, Version=8.0.0.0, Culture=neutral, PublicKeyToken=7cec85d7bea7798e",
        "DbType": 104,
        "DbTypeText": "CHAR",
        "DbTypeTextFull": "CHAR(16 BYTE)",
        "MaxLength": 16,
        "IsPrimary": true,
        "IsIdentity": false,
        "IsNullable": false,
        "Coment": "",
        "Comment": "",
        "DefaultValue": "",
        "Position": 5
      }
    ],
    "UniquesDict": {
      "PRODUCTBASE1": {
        "Name": null,
        "Columns": [
          {
            "Column": {
              "Name": "PRODUCTNAME",
              "CsType": "System.String, System.Private.CoreLib, Version=8.0.0.0, Culture=neutral, PublicKeyToken=7cec85d7bea7798e",
              "DbType": 126,
              "DbTypeText": "VARCHAR2",
              "DbTypeTextFull": "VARCHAR2(100 BYTE)",
              "MaxLength": 100,
              "IsPrimary": false,
              "IsIdentity": false,
              "IsNullable": true,
              "Coment": "",
              "Comment": "",
              "DefaultValue": "",
              "Position": 6
            },
            "IsDesc": false
          }
        ],
        "IsUnique": false
      }
    },
    "IndexesDict": {
      "PRODUCTBASE1": {
        "Name": null,
        "Columns": [
          {
            "Column": {
              "Name": "PRODUCTNAME",
              "CsType": "System.String, System.Private.CoreLib, Version=8.0.0.0, Culture=neutral, PublicKeyToken=7cec85d7bea7798e",
              "DbType": 126,
              "DbTypeText": "VARCHAR2",
              "DbTypeTextFull": "VARCHAR2(100 BYTE)",
              "MaxLength": 100,
              "IsPrimary": false,
              "IsIdentity": false,
              "IsNullable": true,
              "Coment": "",
              "Comment": "",
              "DefaultValue": "",
              "Position": 6
            },
            "IsDesc": false
          }
        ],
        "IsUnique": false
      }
    },
    "ForeignsDict": {},
    "Uniques": [
      {
        "Name": null,
        "Columns": [
          {
            "Column": {
              "Name": "PRODUCTNAME",
              "CsType": "System.String, System.Private.CoreLib, Version=8.0.0.0, Culture=neutral, PublicKeyToken=7cec85d7bea7798e",
              "DbType": 126,
              "DbTypeText": "VARCHAR2",
              "DbTypeTextFull": "VARCHAR2(100 BYTE)",
              "MaxLength": 100,
              "IsPrimary": false,
              "IsIdentity": false,
              "IsNullable": true,
              "Coment": "",
              "Comment": "",
              "DefaultValue": "",
              "Position": 6
            },
            "IsDesc": false
          }
        ],
        "IsUnique": false
      }
    ],
    "Indexes": [
      {
        "Name": null,
        "Columns": [
          {
            "Column": {
              "Name": "PRODUCTNAME",
              "CsType": "System.String, System.Private.CoreLib, Version=8.0.0.0, Culture=neutral, PublicKeyToken=7cec85d7bea7798e",
              "DbType": 126,
              "DbTypeText": "VARCHAR2",
              "DbTypeTextFull": "VARCHAR2(100 BYTE)",
              "MaxLength": 100,
              "IsPrimary": false,
              "IsIdentity": false,
              "IsNullable": true,
              "Coment": "",
              "Comment": "",
              "DefaultValue": "",
              "Position": 6
            },
            "IsDesc": false
          }
        ],
        "IsUnique": false
      }
    ],
    "Foreigns": []
  }
]

[2881099]

仔细对比一下，和文档 json schema 的区别。我抽不出时间帮你检查。