-
Notifications
You must be signed in to change notification settings - Fork 0
/
Connection.cs
74 lines (61 loc) · 1.98 KB
/
Connection.cs
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
using System.Collections.Generic;
using System.Configuration;
using System.Data.SqlClient;
using System.Linq;
using System.Reflection;
using System.Windows;
namespace SatelliteDataScripter
{
public class Connection
{
private IEnumerable<Schema> schemas;
public MainWindowModel Model { get; set; }
public string Name { get; set; }
public string ConnectionString { get; set; }
public IEnumerable<Schema> Schemas
{
get
{
if (schemas == null)
{
schemas = TryLoadSchemas();
}
return schemas;
}
}
public Connection(MainWindowModel model, ConnectionStringSettings connectionString)
{
Name = connectionString.Name;
ConnectionString = connectionString.ConnectionString;
Model = model;
}
public override string ToString()
{
return Name;
}
private IEnumerable<Schema> TryLoadSchemas()
{
try
{
return LoadSchemas().ToList();
}
catch (SqlException)
{
MessageBox.Show(string.Format("Error connecting to '{0}'. Please check the connection string in {1}.exe.config.", Name, Assembly.GetExecutingAssembly().GetName().Name));
return new List<Schema>();
}
}
private IEnumerable<Schema> LoadSchemas()
{
using (var adapter = new SqlDataAdapter("select distinct TABLE_SCHEMA from INFORMATION_SCHEMA.TABLES where TABLE_TYPE = 'BASE TABLE' order by 1", ConnectionString))
{
var dataTable = new TablesDataSet.SchemaDataTable();
adapter.Fill(dataTable);
foreach (TablesDataSet.SchemaRow row in dataTable.Rows)
{
yield return new Schema(this, row);
}
}
}
}
}