关系数据库元数据处理类(一) 创建MSSQL元数据具体处理类

public class SqlServer : BaseMetadata
    {

        public SqlServer(string connectionString)
            : base(new DbUtility(connectionString, DbProviderType.SqlServer))
        {

        }

        protected override string GetDataBaseSting()
        {
            return "Select name FROM Master..SysDatabases order by Name";
        }

        protected override string GetDataTableString(string database = "")
        {
            return "SELECT " +
                   " Name = case when a.colorder = 1 then d.name else '' end," + //表名称
                   " Explain = case when a.colorder = 1 then isnull(f.value, '') else '' end " + //表说明
                   " FROM syscolumns a " +
                   " inner join sysobjects d on a.id = d.id and d.xtype = 'U' and d.name <> 'sys.extended_properties' " +
                   " left join sys.extended_properties f on a.id = f.major_id and f.minor_id = 0 " +
                   " Where (case when a.colorder = 1 then d.name else '' end) <>''";
        }

        protected override string GetDataColumnString()
        {
            return "SELECT  " +
                   "TableName= d.name," +
                   "Name = a.name, " +
                   "IsMarke =(case when COLUMNPROPERTY( a.id,a.name,'IsIdentity')=1 then '1'else '0' end)," +
                   "IsPrimarykey= (case when (SELECT count(*) FROM sysobjects WHERE (name in (SELECT name FROM sysindexes WHERE (id = a.id) AND (indid in (SELECT indid FROM sysindexkeys WHERE (id = a.id) AND (colid in (SELECT colid FROM syscolumns WHERE (id = a.id) AND (name = a.name))))))) AND (xtype = 'PK'))>0 then '1' else '0' end)," +
                   "Type =b.name," +
                   "Bytes=a.length, " +
                   "Length=COLUMNPROPERTY(a.id,a.name,'PRECISION')," +
                   "DecimalPlaces = isnull(COLUMNPROPERTY(a.id,a.name,'Scale'),0)," +
                   "IsNull=(case when a.isnullable=1 then '1'else '0' end), " +
                   "DefaultValue=isnull(e.text,'')," +
                   "Explain=isnull(g.[value], ' ')" +
                   " FROM syscolumns a left join systypes b on a.xtype=b.xusertype inner join sysobjects d on a.id=d.id and d.xtype='U' and d.name<>'dtproperties' left join syscomments e on a.cdefault=e.id left join sys.extended_properties g on a.id=g.major_id AND a.colid=g.minor_id left join sys.extended_properties f on d.id=f.class and f.minor_id=0 where b.name is not null --WHERE d.name='要查询的表' --如果只查询指定表,加上此条件 order by a.id,a.colorder";
        }

        protected override string GetDataRelationString()
        {
            return
                "SELECT 外键表ID = b.fkeyid , ForeignTableName = object_name(b.fkeyid) , 外键列ID = b.fkey , ForeignKeyName = (SELECT name FROM syscolumns WHERE colid = b.fkey AND id = b.fkeyid) , 主键表ID = b.rkeyid , PrimaryTableName = object_name(b.rkeyid) , 主键列ID = b.rkey , PrimaryKeyName = (SELECT name FROM syscolumns WHERE colid = b.rkey AND id = b.rkeyid) , 级联更新 = ObjectProperty(a.id,'CnstIsUpdateCascade') , 级联删除 = ObjectProperty(a.id,'CnstIsDeleteCascade') FROM sysobjects a JOIN sysforeignkeys b ON a.id = b.constid JOIN sysobjects c ON a.parent_obj = c.id WHERE a.xtype = 'F' AND c.xtype = 'U' ";
        }

        protected override List<Database> ConversionDatabase(DataTable table)
        {
            return Mapper.DynamicMap<IDataReader, List<Database>>(table.CreateDataReader());
        }

        protected override List<Table> ConversionDataTable(DataTable table)
        {
            return Mapper.DynamicMap<IDataReader, List<Table>>(table.CreateDataReader());
        }

        protected override List<Column> ConversionColumn(DataTable table)
        {
            return Mapper.DynamicMap<IDataReader, List<Column>>(table.CreateDataReader());
        }

        protected override List<Relation> ConversionDataRelation(DataTable table)
        {
            return Mapper.DynamicMap<IDataReader, List<Relation>>(table.CreateDataReader());
        }
    }