Yii2中mssql和sql server数据库如何使用
创始人
2024-12-23 17:43:07
0次

  1.首先找到yii2解析mssql的scheme:

  vendor/yiisoft/yii2/db/mssql/Schema.php

  2.更改解析代码:

  ⑴找到findColumns 的函数 大概在232行左右

  ⑵替代解析 代码如下 :

  /**

  * Collects the metadata of table columns.

  * @param TableSchema $table the table metadata

  * @return boolean whether the table exists in the database

  */

  protected function findColumns($table)

  {

  $pdo = $this->db->getSlavePdo();

  $version = explode('.', $pdo->getAttribute(\PDO::ATTR_SERVER_VERSION));

  //var_dump($version);exit;

  if (intval($version[0]<9)) {   $sql = <<   SELECT   column_name = a.name,   is_identity = case when exists(SELECT 1 FROM sysobjects where xtype='PK' and parent_obj=a.id and name in (   SELECT name FROM sysindexes WHERE indid in(   SELECT indid FROM sysindexkeys WHERE id = a.id AND colid=a.colid))) then 1 else 0 end,   data_type = case   when b.name in ('ntext','datetime') then b.name   when isnull(COLUMNPROPERTY(a.id,a.name,'Scale'),0)>0 then

  b.name + '(' + convert(varchar(20), COLUMNPROPERTY(a.id,a.name,'PRECISION')) + ','+convert(varchar(10), COLUMNPROPERTY(a.id,a.name,'Scale'))+')'

  else b.name + '(' + convert(varchar(20), COLUMNPROPERTY(a.id,a.name,'PRECISION')) + ')' end ,

  is_nullable = case when a.isnullable=1 then 'Yes' else 'No' end,

  column_default = isnull(e.text,''),

  comment = isnull(g.[value],'')

  FROM

  syscolumns a

  left join

  systypes b

  on

  a.xusertype=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

  sysproperties g

  on

  a.id=g.id and a.colid=g.smallid

  left join

  sysproperties f

  on

  d.id=f.id and f.smallid=0

  where

  d.name='{$table->fullName}'

  order by

  a.id,a.colorder

  SQL2000;

  }

  else {

  $columnsTableName = 'INFORMATION_SCHEMA.COLUMNS';

  $whereSql = "[t1].[table_name] = '{$table->name}'";

  if ($table->catalogName !== null) {

  $columnsTableName = "{$table->catalogName}.{$columnsTableName}";

  $whereSql .= " AND [t1].[table_catalog] = '{$table->catalogName}'";

  }

  if ($table->schemaName !== null) {

  $whereSql .= " AND [t1].[table_schema] = '{$table->schemaName}'";

  }

  $columnsTableName = $this->quoteTableName($columnsTableName);

  $sql = <<   SELECT   [t1].[column_name], [t1].[is_nullable], [t1].[data_type], [t1].[column_default],   COLUMNPROPERTY(OBJECT_ID([t1].[table_schema] + '.' + [t1].[table_name]), [t1].[column_name], 'IsIdentity') AS is_identity,   CONVERT(VARCHAR, [t2].[value]) AS comment   FROM {$columnsTableName} AS [t1]   LEFT OUTER JOIN [sys].[extended_properties] AS [t2] ON   [t2].[minor_id] = COLUMNPROPERTY(OBJECT_ID([t1].[TABLE_SCHEMA] + '.' + [t1].[TABLE_NAME]), [t1].[COLUMN_NAME], 'ColumnID') AND   OBJECT_NAME([t2].[major_id]) = [t1].[table_name] AND   [t2].[class] = 1 AND   [t2].[class_desc] = 'OBJECT_OR_COLUMN' AND   [t2].[name] = 'MS_Description'   WHERE {$whereSql}   SQL;   }   try {   $columns = $this->db->createCommand($sql)->queryAll();

  if (empty($columns)) {

  return false;

  }

  } catch (\Exception $e) {

  return false;

  }

  foreach ($columns as $column) {

  $column = $this->loadColumnSchema($column);

  foreach ($table->primaryKey as $primaryKey) {

  if (strcasecmp($column->name, $primaryKey) === 0) {

  $column->isPrimaryKey = true;

  break;

  }

  }

  if ($column->isPrimaryKey && $column->autoIncrement) {

  $table->sequenceName = '';

  }

  $table->columns[$column->name] = $column;

  }

  return true;

  }

  3.分析这段代码:

  ⑴获取数据库的版本:

  $pdo = $this->db->getSlavePdo();

  $version = explode('.', $pdo->getAttribute(\PDO::ATTR_SERVER_VERSION));

  ⑵根据版本解析:

  if (intval($version[0]<9)) { }else{}   ⑶解析sql2000:   $sql = <<   SELECT   column_name = a.name,   is_identity = case when exists(SELECT 1 FROM sysobjects where xtype='PK' and parent_obj=a.id and name in (   SELECT name FROM sysindexes WHERE indid in(   SELECT indid FROM sysindexkeys WHERE id = a.id AND colid=a.colid))) then 1 else 0 end,   data_type = case   when b.name in ('ntext','datetime') then b.name   when isnull(COLUMNPROPERTY(a.id,a.name,'Scale'),0)>0 then

  b.name + '(' + convert(varchar(20), COLUMNPROPERTY(a.id,a.name,'PRECISION')) + ','+convert(varchar(10), COLUMNPROPERTY(a.id,a.name,'Scale'))+')'

  else b.name + '(' + convert(varchar(20), COLUMNPROPERTY(a.id,a.name,'PRECISION')) + ')' end ,

  is_nullable = case when a.isnullable=1 then 'Yes' else 'No' end,

  column_default = isnull(e.text,''),

  comment = isnull(g.[value],'')

  FROM

  syscolumns a

  left join

  systypes b

  on

  a.xusertype=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

  sysproperties g

  on

  a.id=g.id and a.colid=g.smallid

  left join

  sysproperties f

  on

  d.id=f.id and f.smallid=0

  where

  d.name='{$table->fullName}'

  order by

  a.id,a.colorder

  SQL2000;

  ⑷else 就是原来的解析方式 3.打开sql的数据库scheme的缓存,在db.php文件中添加 :'enableSchemaCache'=>true 既可以。

相关内容

热门资讯

空调连续工作多久需要停机休息 空调连续工作的时间取决于多个因素,包括空调的型号、功率、使用环境和维护情况等。一般来说,空调可以连续...
空调哪个符号是除湿的 空调除湿功能通常用一个水滴形状的符号表示。不同品牌和型号的空调遥控器可能会有所差异,但一般来说,除湿...
格力空调多长时间加一次氟利昂 1、一般情况下,空调对氟利昂的使用量是非常小的,所以在空调使用了四年左右的时候再考虑加也没问题。2、...
空调用多长时间需要加氟一次 一般情况下是五年。当出现以下这几种情况时,空调才需要加氟。1、空调的室内机和室外机各有两个接口,当接...
格调生活·C标思享荟:卡萨帝在... 9月12日的郑州龙湖金融岛,夜风轻拂,灯光璀璨。“C标时刻共传奇——卡萨帝思享荟暨20周年品牌盛典郑...
品牌价值破千亿、高端份额持续领... 9月12日,“C标时刻共传奇——卡萨帝思享荟暨20周年品牌盛典郑州站”在郑州龙湖金融岛举办。2026...
空调主板坏了修800还是换新的 空调主板坏了是修还是换新,需要考虑多个因素,以下是一些建议:1. 维修成本:如果维修费用较低,比如 ...
空调开多久需要休息多长时间 问题:空调开多久需要休息多长时间回答:1、在使用空调的过程中,一般空调开7~8个小时左右需要休息2~...
中央空调多长时间清洗一次 1、一般空调开机前清洗一次即可,空调开机中间时段再清洗一次,空调关机时清洗一次,这样比较合理。2、空...
中央空调氟利昂多久加一次 看空调制热和制冷程度,很多人的观点认为氟利昂必须一年放一次,其实这个观点是错误的,理解上面有点偏差,...