aboutsummaryrefslogtreecommitdiff
path: root/src/WixBuildTools.TestSupport/Query.cs
blob: bbd9f89ae3eb830e54e54056adf07e45dda1918e (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
// Copyright (c) .NET Foundation and contributors. All rights reserved. Licensed under the Microsoft Reciprocal License. See LICENSE.TXT file in the project root for full license information.

namespace WixBuildTools.TestSupport
{
    using System;
    using System.Collections.Generic;
    using System.IO;
    using System.Linq;
    using System.Text;
    using WixToolset.Dtf.Compression.Cab;
    using WixToolset.Dtf.WindowsInstaller;

    public class Query
    {
        public static string[] QueryDatabase(string path, string[] tables)
        {
            var results = new List<string>();

            if (tables?.Length > 0)
            {
                var sb = new StringBuilder();
                using (var db = new Database(path))
                {
                    foreach (var table in tables)
                    {
                        if (!db.IsTablePersistent(table))
                        {
                            continue;
                        }

                        using (var view = db.OpenView("SELECT * FROM `{0}`", table))
                        {
                            view.Execute();

                            Record record;
                            while ((record = view.Fetch()) != null)
                            {
                                sb.Clear();
                                sb.AppendFormat("{0}:", table);

                                using (record)
                                {
                                    for (var i = 0; i < record.FieldCount; ++i)
                                    {
                                        if (i > 0)
                                        {
                                            sb.Append("\t");
                                        }

                                        sb.Append(record[i + 1]?.ToString());
                                    }
                                }

                                results.Add(sb.ToString());
                            }
                        }
                    }
                }
            }

            results.Sort();
            return results.ToArray();
        }

        public static CabFileInfo[] GetCabinetFiles(string path)
        {
            var cab = new CabInfo(path);

            var result = cab.GetFiles();

            return result.Select(c => c).ToArray();
        }

        public static void ExtractStream(string path, string streamName, string outputPath)
        {
            Directory.CreateDirectory(Path.GetDirectoryName(outputPath));

            using (var db = new Database(path))
            using (var view = db.OpenView("SELECT `Data` FROM `_Streams` WHERE `Name` = '{0}'", streamName))
            {
                view.Execute();

                using (var record = view.Fetch())
                {
                    record.GetStream(1, outputPath);
                }
            }
        }

        public static void ExtractSubStorage(string path, string subStorageName, string outputPath)
        {
            Directory.CreateDirectory(Path.GetDirectoryName(outputPath));

            using (var db = new Database(path))
            using (var view = db.OpenView("SELECT `Name`, `Data` FROM `_Storages` WHERE `Name` = '{0}'", subStorageName))
            {
                view.Execute();

                using (var record = view.Fetch())
                {
                    var name = record.GetString(1);
                    record.GetStream(2, outputPath);
                }
            }
        }

        public static string[] GetSubStorageNames(string path)
        {
            var result = new List<string>();

            using (var db = new Database(path))
            using (var view = db.OpenView("SELECT `Name` FROM `_Storages`"))
            {
                view.Execute();

                Record record;
                while ((record = view.Fetch()) != null)
                {
                    var name = record.GetString(1);
                    result.Add(name);
                }
            }

            result.Sort();
            return result.ToArray();
        }
    }
}