1

状況：アプリケーション更新プログラムを作成しました。問題は、更新されたアプリケーションで使用されるデータベースが異なる可能性があることです。

バックアップダンプを作成し、さまざまなデータベースタイプのそのダンプを片手で復元できる.dllを検索しました。しかし悲しいことに、利用できるものはありませんでした。

私の最初のアイデアは、すべてのDatabaseTypeのユースケースを作成し、config.txtファイルで指定された正しいユースケースを使用することでした。しかし、私の上司はその解決策が気に入らなかった。そこで、NHibernate（更新ファイルの送信にも使用されます）を使用してデータベースのバックアップを作成できるかどうかを確認しました。悲しいことに、これは可能ですが、実行可能ではありません。それはあまりにも多くのオーバーヘッドを生成するので。Rhino.ETLも調べましたが、残念ながら、Rhino.ETLを使用するための十分なドキュメントがありません。

ですから、他にうまくいくかもしれないことを誰かが知っているかどうか尋ねたいと思います。それとも、上司の希望に反してユースケースごとのアプローチを使用することを辞任しましたか？

4

2 に答える 2

3

NHibernate を使用してバックアップと復元を行いました。エクスポートとインポートでのエンティティの順序は重要です

ExportData(config, config.BuildSessionFactory(), dataFile, config.ClassMappings.Select(m => m.EntityName));

public void ExportData(Configuration config, ISessionFactory factory, string dataFile, IEnumerable<string> entitiesToExport)
{
    File.Delete(dataFile);
    using (var zip = new ZipFile(dataFile) { CompressionMethod = CompressionMethod.Deflate, CompressionLevel = CompressionLevel.BestCompression })
    using (var session = factory.OpenStatelessSession())
    using (var tx = session.BeginTransaction())
    {
        foreach (var name in entitiesToExport)
        {
            // copy for closure
            var entityName = name;
            zip.AddEntry(entityName + ".csv", (tablename, outstream) =>
            {
                using (var writer = new StreamWriter(outstream))
                {
                    // mapping der Klasse
                    var entityMap = config.GetClassMapping(entityName);
                    // only properties, no Collections (toMany)
                    var properties = entityMap.PropertyClosureIterator.Where(prop => prop.ColumnSpan > 0).ToArray();

                    // write csv(tsv) header
                    writer.WriteLine(string.Join(SEPERATOR, ToPropertyNames(properties)));

                    var classMetaData = factory.GetClassMetadata(entityName);

                    const int pagesize = 10000;
                    int page = 0;
                    IList<object> objects;
                    do
                    {
                        objects = session.CreateCriteria(entityName)
                            .SetFirstResult(page * pagesize)
                            .SetMaxResults(pagesize)
                            .AddOrder(Order.Asc(Projections.Id()))
                            .List<object>();

                        foreach (var obj in objects)
                        {
                            // get property values as string
                            var values = ToPropertyValues(factory, classMetaData, properties, string.Empty, obj).Select(Serialize);

                            writer.WriteLine(string.Join(SEPERATOR, values));
                        }

                        page++;
                    } while (objects.Count > 0);
                }
            });
        }
        zip.Save(dataFile);
    }
}

とインポート

public void ImportData(NHCfg.Configuration config, ISessionFactory factory, string dataFile)
{
    using (var zip = new ZipFile(dataFile))
    using (var session = factory.OpenSession())
    using (var tx = session.BeginTransaction())
    {
        var filesAndMaps = from file in zip.EntryFileNames
                           join map in config.ClassMappings on Path.GetFileNameWithoutExtension(file) equals map.EntityName
                           select new { Filename = file, Entitymap = map };

        foreach (var fileAndMap in filesAndMaps)
        {
            using (Stream stream = zip[fileAndMap.Filename].OpenReader())
            using (StreamReader reader = new StreamReader(stream))
            {
                // mapping der Klasse
                var classMetadata = factory.GetClassMetadata(fileAndMap.Entitymap.EntityName);

                var propertyNames = reader.ReadLine().Split(SEPERATOR[0]).Select(str => str.EndsWith("_Id") ? str.Remove(str.Length - "_Id".Length) : str).ToArray();

                // propertyNamen(/pfade) und typen aus dem mapping holen
                List<string> names = new List<string>();
                List<IType> itypes = new List<IType>();

                names.AddRange(classMetadata.PropertyNames);
                itypes.AddRange(classMetadata.PropertyTypes);
                for (int index = names.Count - 1; index >= 0; index--)
                {
                    var propertyType = itypes[index];
                    if (propertyType.IsComponentType)
                    {
                        var basename = names[index];
                        var componentType = (ComponentType)propertyType;
                        names.RemoveAt(index);
                        names.InsertRange(index, componentType.PropertyNames.Select(name => basename + "." + name));
                        itypes.RemoveAt(index);
                        itypes.InsertRange(index, componentType.Subtypes);
                        index += componentType.Subtypes.Length;
                    }
                    else if (propertyType.IsEntityType)
                    {
                        itypes[index] = factory.GetClassMetadata(((EntityType)propertyType).GetAssociatedEntityName()).IdentifierType;
                    }
                }

                // mit den namen aus der csv abgleichen um den index im array der namen und typen zu bestimmen
                int[] indices = new int[propertyNames.Length];
                for (int i = 0; i < indices.Length; i++)
                {
                    indices[i] = names.IndexOf(propertyNames[i]);
                }

                object[] deserialisedValues = new object[itypes.Count];
                object[] objectValues = new object[classMetadata.PropertyTypes.Length];

                string line;
                while ((line = reader.ReadLine()) != null)
                {
                    string[] serialisedValues = line.Split(SEPERATOR[0]);

                    // Werte deserialisieren
                    for (int i = 0; i < serialisedValues.Length; i++)
                    {
                        // nur deserialisieren wenn es das property überhaupt noch gibt
                        if (indices[i] >= 0)
                            deserialisedValues[indices[i]] = Deserialize(serialisedValues[i], itypes[indices[i]].ReturnedClass);
                    }

                    int offset = 0;
                    for (int i = 0; i < objectValues.Length; i++)
                    {
                        var propertyType = classMetadata.PropertyTypes[i];
                        if (propertyType.IsComponentType)
                        {
                            objectValues[i] = ToComponentObject(deserialisedValues, ref offset, (ComponentType)propertyType, session);
                        }
                        else
                        {
                            objectValues[i] = (propertyType.IsEntityType && deserialisedValues[offset] != null) ?
                                session.Load(((ManyToOneType)propertyType).GetAssociatedEntityName(), deserialisedValues[offset]) :
                                deserialisedValues[offset];

                            offset++;
                        }
                    }
                    object entity = classMetadata.Instantiate(null, EntityMode.Poco);

                    classMetadata.SetPropertyValues(entity, objectValues, EntityMode.Poco);

                    session.Save(entity);
                }
            }
        }
        tx.Commit();
    }
}

存在しない機能は読者の演習です

于 2012-09-14T08:43:59.707 に答える
0

良い答え Firo、メソッド「ToPropertyNames」、「ToPropertyValues」、および「ToComponentObject」のコードを配置できますか?

それを使用するには、ライブラリDotNetZipが必要であることを追加します

于 2015-01-09T00:15:32.317 に答える