1 #region MIT license
2 //
3 // MIT license
4 //
5 // Copyright (c) 2007-2008 Jiri Moudry, Pascal Craponne
6 //
7 // Permission is hereby granted, free of charge, to any person obtaining a copy
8 // of this software and associated documentation files (the "Software"), to deal
9 // in the Software without restriction, including without limitation the rights
10 // to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
11 // copies of the Software, and to permit persons to whom the Software is
12 // furnished to do so, subject to the following conditions:
13 //
14 // The above copyright notice and this permission notice shall be included in
15 // all copies or substantial portions of the Software.
16 //
17 // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
18 // IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
19 // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
20 // AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
21 // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
22 // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
23 // THE SOFTWARE.
24 //
25 #endregion
26 using System.Collections.Generic;
27 using System.Data;
28 using DbLinq.Util;
29 using DbLinq.Vendor;
30 
31 namespace DbLinq.Ingres
32 {
33     partial class IngresSchemaLoader
34     {
GetFullType(IDataTableColumn column)35         protected virtual string GetFullType(IDataTableColumn column)
36         {
37             switch (column.SqlType.ToLower())
38             {
39             case "c":
40             case "char":
41             case "nchar":
42             case "varchar":
43             case "nvarchar":
44             case "long varchar":
45             case "text":
46             case "integer":
47                 return column.SqlType + "(" + column.Length + ")";
48 
49             case "decimal":
50                 return column.SqlType + "(" + column.Length + ", " + column.Scale + ")";
51 
52             default:
53                 return column.SqlType;
54             }
55         }
56 
ReadColumn(IDataRecord rdr)57         protected virtual IDataTableColumn ReadColumn(IDataRecord rdr)
58         {
59             var column = new DataTableColumn();
60             int field = 0;
61             column.TableSchema = rdr.GetAsString(field++).Trim();
62             column.TableName = rdr.GetAsString(field++).Trim();
63             column.ColumnName = rdr.GetAsString(field++).Trim();
64             string nullableStr = rdr.GetAsString(field++);
65             column.Nullable = nullableStr == "Y";
66             column.SqlType = rdr.GetAsString(field++).Trim();
67             column.DefaultValue = rdr.GetAsString(field++);
68             column.Generated = column.DefaultValue != null && column.DefaultValue.StartsWith("next value for");
69 
70             column.Length = rdr.GetAsNullableNumeric<long>(field++);
71             column.Scale = rdr.GetAsNullableNumeric<int>(field++);
72             column.FullType = GetFullType(column);
73             return column;
74         }
75 
ReadColumns(IDbConnection connectionString, string databaseName)76         protected override IList<IDataTableColumn> ReadColumns(IDbConnection connectionString, string databaseName)
77         {
78             const string sql = @"SELECT t.table_owner, t.table_name, column_name, " +
79                 "column_nulls, column_datatype, column_default_val, " +
80                 "column_length, column_scale " +
81                 "FROM iicolumns c join iitables t on " +
82                 "(c.table_name=t.table_name and c.table_owner=t.table_owner) " +
83                 "WHERE t.table_owner <> '$ingres' and t.table_type in ('T', 'V') " +
84                 "AND t.table_name NOT LIKE 'ii%' " +
85                 "ORDER BY column_sequence";
86 
87             return DataCommand.Find<IDataTableColumn>(connectionString, sql, ReadColumn);
88         }
89     }
90 }
91