annotate Source/Templates/MySql.ttinclude @ 0:f990fcb411a9

Копия текущей версии из github
author cin
date Thu, 27 Mar 2014 21:46:09 +0400
parents
children
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
0
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1 <#
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
2 ConnectionType = "MySql.Data.MySqlClient.MySqlConnection, MySql.Data";
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
3 #><#+
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
4
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
5 private void LoadServerMetadata()
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
6 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
7 var tables = CreateList(new { ID = "", Table = new Table() });
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
8 var columns = CreateList(new { ID = "", Column = new Column() });
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
9
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
10 using (var conn = GetConnection())
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
11 using (var cmd = conn.CreateCommand())
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
12 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
13 string schemasToSkip = "'information_schema', 'cr_debug', 'mysql'";
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
14
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
15 // Load tables & views.
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
16 //
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
17
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
18 cmd.CommandText = "SELECT DATABASE()";
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
19 _databaseName = Convert.ToString(cmd.ExecuteScalar());
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
20
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
21 cmd.CommandText = string.Format(@"
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
22 SELECT
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
23 CONCAT(TABLE_SCHEMA, '.', TABLE_NAME),
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
24 TABLE_SCHEMA,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
25 TABLE_NAME,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
26 TABLE_TYPE
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
27 FROM
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
28 INFORMATION_SCHEMA.tables
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
29 WHERE
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
30 TABLE_SCHEMA NOT IN ({0}) AND
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
31 TABLE_TYPE IN ('BASE TABLE', 'VIEW')
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
32 {1}",
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
33 schemasToSkip,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
34 GetDatabaseSqlFilter(""));
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
35
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
36 using (var rd = cmd.ExecuteReader())
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
37 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
38 while (rd.Read())
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
39 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
40 var t = new
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
41 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
42 ID = Convert.ToString(rd[0]),
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
43 Table = new Table
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
44 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
45 Owner = null, // there is no concept of table owner in MySql
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
46 TableName = rd[2].ToString(),
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
47 ClassName = rd[2].ToString(),
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
48 DataContextPropertyName = rd[2].ToString(),
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
49 IsView = rd[3].ToString() == "VIEW",
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
50 BaseClassName = BaseEntityClass,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
51 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
52 };
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
53
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
54 tables.Add(t);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
55 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
56 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
57
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
58 cmd.CommandText = "SELECT @@session.sql_mode";
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
59 string sqlMode = Convert.ToString(cmd.ExecuteScalar());
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
60
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
61 // Load columns.
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
62 //
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
63 cmd.CommandText = string.Format(@"
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
64 SELECT
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
65 CONCAT(TABLE_SCHEMA, '.', TABLE_NAME) as id,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
66 CASE WHEN IS_NULLABLE = 'YES' THEN 1 ELSE 0 END as isNullable,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
67 ORDINAL_POSITION as colid,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
68 COLUMN_NAME as name,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
69 c.DATA_TYPE as dataType,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
70 CHARACTER_MAXIMUM_LENGTH as length,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
71 NUMERIC_PRECISION as prec,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
72 NUMERIC_SCALE as scale,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
73 EXTRA = 'auto_increment' as isIdentity,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
74 c.COLUMN_TYPE as columnType,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
75 COLUMN_DEFAULT as columnDefault,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
76 EXTRA as extra
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
77 FROM
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
78 INFORMATION_SCHEMA.COLUMNS c
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
79 WHERE
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
80 TABLE_SCHEMA NOT IN ({0})
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
81 {1}",
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
82 schemasToSkip,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
83 GetDatabaseSqlFilter(""));
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
84
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
85 using (var rd = cmd.ExecuteReader())
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
86 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
87 while (rd.Read())
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
88 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
89 var col = new
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
90 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
91 ID = Convert.ToString(rd["id"]),
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
92 Column = new Column
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
93 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
94 ID = Convert.ToInt16 (rd["colid"]),
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
95 ColumnName = Convert.ToString (rd["name"]),
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
96 MemberName = Convert.ToString (rd["name"]),
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
97 ColumnType = Convert.ToString (rd["dataType"]),
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
98 IsNullable = Convert.ToBoolean(rd["isNullable"]),
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
99 IsIdentity = Convert.ToBoolean(rd["isIdentity"]),
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
100 Length = rd.IsDBNull(rd.GetOrdinal("length")) ? 0 : Convert.ToInt64(rd["length"]),
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
101 Precision = rd.IsDBNull(rd.GetOrdinal("prec")) ? 0 : Convert.ToInt32(rd["prec"]),
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
102 Scale = rd.IsDBNull(rd.GetOrdinal("scale")) ? 0 : Convert.ToInt32(rd["scale"]),
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
103 ColumnDefault = Convert.ToString(rd["columnDefault"]),
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
104 Extra = Convert.ToString(rd["extra"]).ToUpper()
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
105 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
106 };
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
107
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
108 var c = col.Column;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
109 var columnType = Convert.ToString(rd["columnType"]).ToLower();
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
110 var unsigned = columnType.Contains("unsigned");
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
111 var realAsFloat = sqlMode.ToLower().Contains("real_as_float");
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
112
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
113 switch (c.ColumnType)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
114 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
115 case "longtext" :
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
116 case "mediumtext" :
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
117 case "tinytext" :
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
118 case "text" : c.Type = "string"; c.DbType = DbType.String; c.SqlDbType = SqlDbType.Text; break;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
119 case "binary" : c.Type = "byte[]"; c.DbType = DbType.Binary; c.SqlDbType = SqlDbType.Binary; break;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
120 case "date" : c.Type = "DateTime"; c.DbType = DbType.Date; c.SqlDbType = SqlDbType.Date; break;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
121 case "time" : c.Type = "DateTime"; c.DbType = DbType.Time; c.SqlDbType = SqlDbType.Time; break;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
122 case "bit" : c.Type = "bool"; c.DbType = DbType.Boolean; c.SqlDbType = SqlDbType.Bit; break;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
123 case "numeric" :
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
124 case "decimal" :
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
125 case "dec" :
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
126 case "fixed" : c.Type = "decimal"; c.DbType = DbType.Decimal; c.SqlDbType = SqlDbType.Decimal; break;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
127 case "datetime" : c.Type = "DateTime"; c.DbType = DbType.DateTime; c.SqlDbType = SqlDbType.DateTime; break;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
128 case "float" : c.Type = "float"; c.DbType = DbType.Single; c.SqlDbType = SqlDbType.Float; break;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
129 case "double" : c.Type = "double"; c.DbType = DbType.Double; c.SqlDbType = SqlDbType.Float; break;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
130 case "varbinary" : c.Type = "byte[]"; c.DbType = DbType.Binary; c.SqlDbType = SqlDbType.VarBinary; break;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
131 case "varchar" : c.Type = "string"; c.DbType = DbType.String; c.SqlDbType = SqlDbType.VarChar; break;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
132 case "year" : c.Type = "DateTime"; c.DbType = DbType.Date; c.SqlDbType = SqlDbType.Date; break;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
133 case "enum" :
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
134 case "set" : c.Type = "string"; c.DbType = DbType.String; c.SqlDbType = SqlDbType.VarChar; break;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
135 case "bool" :
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
136 case "boolean" : c.Type = "bool"; c.DbType = DbType.Boolean; c.SqlDbType = SqlDbType.Bit; break;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
137 case "serial" : c.Type = "ulong"; c.DbType = DbType.UInt64; c.SqlDbType = SqlDbType.BigInt; break;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
138 case "mediumblob" :
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
139 case "longblob" :
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
140 case "blob" : c.Type = "byte[]"; c.DbType = DbType.Binary; c.SqlDbType = SqlDbType.Image; break;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
141 case "tinyblob" : c.Type = "byte[]"; c.DbType = DbType.Binary; c.SqlDbType = SqlDbType.Binary; break;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
142
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
143 case "smallint" : c.Type = unsigned ? "ushort" : "short"; c.DbType = unsigned ? DbType.UInt16 : DbType.Int16; c.SqlDbType = SqlDbType.SmallInt; break;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
144 case "mediumint" :
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
145 case "int" :
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
146 case "integer" : c.Type = unsigned ? "uint" : "int"; c.DbType = unsigned ? DbType.UInt32 : DbType.Int32; c.SqlDbType = SqlDbType.Int; break;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
147 case "real" : c.Type = realAsFloat ? "float" : "double"; c.DbType = realAsFloat ? DbType.Single : DbType.Double; c.SqlDbType = SqlDbType.Real; break;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
148 case "bigint" : c.Type = unsigned ? "ulong" : "long"; c.DbType = unsigned ? DbType.UInt64 : DbType.Int64; c.SqlDbType = SqlDbType.BigInt; break;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
149 case "char" : c.Type = "string"; c.DbType = DbType.StringFixedLength; c.SqlDbType = SqlDbType.Char; break;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
150 case "timestamp" :
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
151 c.Type = "DateTime";
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
152 c.DbType = DbType.DateTime;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
153 c.SqlDbType = SqlDbType.Timestamp;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
154
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
155 if(c.ColumnDefault == "CURRENT_TIMESTAMP" || c.Extra.Contains("ON UPDATE CURRENT_TIMESTAMP"))
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
156 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
157 c.Attributes.Add(string.Format(
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
158 "NonUpdatable(OnInsert = {0}, OnUpdate = {1})",
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
159 c.ColumnDefault == "CURRENT_TIMESTAMP" ? "true" : "false",
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
160 c.Extra.Contains("ON UPDATE CURRENT_TIMESTAMP") ? "true" : "false"));
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
161 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
162 break;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
163 case "tinyint" :
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
164 if(columnType == "tinyint(1)")
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
165 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
166 c.Type = "bool";
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
167 c.DbType = DbType.Boolean;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
168 c.SqlDbType = SqlDbType.Bit;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
169 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
170 else
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
171 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
172 c.Type = unsigned ? "byte" : "sbyte";
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
173 c.DbType = unsigned ? DbType.Byte : DbType.SByte;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
174 c.SqlDbType = SqlDbType.TinyInt;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
175 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
176 break;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
177 default :
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
178 throw new System.IO.InvalidDataException(string.Format("Unknown column type: {0}.", c.ColumnType));
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
179 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
180
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
181 switch (c.Type)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
182 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
183 case "string" :
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
184 case "byte[]" : c.IsClass = true; break;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
185 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
186
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
187 if (c.IsNullable && !c.IsClass)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
188 c.Type += "?";
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
189
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
190 columns.Add(col);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
191 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
192 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
193
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
194 // Load PKs.
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
195 //
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
196 cmd.CommandText = string.Format(@"
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
197 SELECT
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
198 CONCAT(k.TABLE_SCHEMA, '.', k.TABLE_NAME) as id,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
199 k.CONSTRAINT_NAME as name,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
200 k.COLUMN_NAME as colname,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
201 k.ORDINAL_POSITION as colid
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
202 FROM
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
203 INFORMATION_SCHEMA.KEY_COLUMN_USAGE k
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
204 JOIN INFORMATION_SCHEMA.TABLE_CONSTRAINTS c ON k.CONSTRAINT_NAME = c.CONSTRAINT_NAME
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
205 WHERE
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
206 c.CONSTRAINT_TYPE='PRIMARY KEY' AND
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
207 k.TABLE_SCHEMA NOT IN ({0})
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
208 {1}
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
209 GROUP BY id, colid",
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
210 schemasToSkip,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
211 GetDatabaseSqlFilter("k"));
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
212
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
213 using (var rd = cmd.ExecuteReader())
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
214 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
215 while (rd.Read())
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
216 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
217 var id = Convert.ToString(rd["id"]);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
218 var colid = Convert.ToInt32 (rd["colid"]);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
219 var colname = Convert.ToString(rd["colname"]);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
220
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
221 columns.Single(_ => _.ID == id && _.Column.ColumnName == colname).Column.PKIndex = colid;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
222 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
223 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
224
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
225 // Load FKs.
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
226 //
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
227 cmd.CommandText = string.Format(@"
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
228 SELECT
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
229 CONSTRAINT_NAME as Name,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
230 CONCAT(TABLE_SCHEMA, '.', TABLE_NAME) as ThisTable,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
231 COLUMN_NAME as ThisColumn,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
232 CONCAT(REFERENCED_TABLE_SCHEMA, '.', REFERENCED_TABLE_NAME) as OtherTable,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
233 REFERENCED_COLUMN_NAME as OtherColumn,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
234 ORDINAL_POSITION as Ordinal
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
235 FROM
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
236 INFORMATION_SCHEMA.key_column_usage
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
237 WHERE
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
238 TABLE_SCHEMA NOT IN ({0}) AND
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
239 REFERENCED_TABLE_NAME IS NOT NULL AND
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
240 REFERENCED_COLUMN_NAME IS NOT NULL
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
241 {1}
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
242 ORDER BY
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
243 ThisTable,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
244 Ordinal",
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
245 schemasToSkip,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
246 GetDatabaseSqlFilter(""));
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
247
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
248 if(!string.IsNullOrEmpty(DatabaseName))
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
249 cmd.CommandText += string.Format(" AND TABLE_SCHEMA = '{0}' ", DatabaseName);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
250
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
251 using (var rd = cmd.ExecuteReader())
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
252 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
253 while (rd.Read())
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
254 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
255 var name = Convert.ToString(rd["Name"]);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
256 var thisTableID = Convert.ToString(rd["ThisTable"]);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
257 var otherTableID = Convert.ToString(rd["OtherTable"]);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
258 var thisColumnName = Convert.ToString(rd["ThisColumn"]);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
259 var otherColumnName = Convert.ToString(rd["OtherColumn"]);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
260
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
261 var thisTable = (from t in tables where t.ID == thisTableID select t.Table).Single();
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
262 var otherTable = (from t in tables where t.ID == otherTableID select t.Table).Single();
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
263 var thisColumn = (from c in columns where c.ID == thisTableID && c.Column.ColumnName == thisColumnName select c.Column).Single();
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
264 var otherColumn = (from c in columns where c.ID == otherTableID && c.Column.ColumnName == otherColumnName select c.Column).Single();
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
265
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
266 if (thisTable.ForeignKeys.ContainsKey(name) == false)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
267 thisTable.ForeignKeys.Add(name, new ForeignKey { KeyName = name, MemberName = name, OtherTable = otherTable });
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
268
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
269 var key = thisTable.ForeignKeys[name];
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
270
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
271 key.ThisColumns. Add(thisColumn);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
272 key.OtherColumns.Add(otherColumn);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
273 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
274 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
275 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
276
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
277 var qc =
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
278 from c in columns
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
279 group c by c.ID into gr
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
280 join t in tables on gr.Key equals t.ID
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
281 select new { t.Table, gr };
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
282
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
283 foreach (var c in qc)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
284 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
285 foreach (var col in from col in c.gr orderby col.Column.ID select col.Column)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
286 c.Table.Columns.Add(col.ColumnName, col);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
287
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
288 // there is no concept of table owner in MySql so we just use table name
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
289 Tables.Add(c.Table.TableName, c.Table);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
290 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
291 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
292
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
293 private string _databaseName;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
294 private string GetDatabaseSqlFilter(string optionalTablePrefix)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
295 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
296 if(string.IsNullOrEmpty(_databaseName)) return "";
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
297 string tablePrefix = string.IsNullOrEmpty(optionalTablePrefix) ? "" : optionalTablePrefix + ".";
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
298 return string.Format(" AND {0}TABLE_SCHEMA = '{1}' ", tablePrefix, _databaseName);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
299 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
300
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
301 public partial class Column
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
302 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
303 public string ColumnDefault;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
304 public string Extra;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
305 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
306
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
307 #>