数据库驱动增加时区设置，统一使用timezone参数配置

Author: liu21st

src/db/PDOConnection.php

@@ -85,6 +85,8 @@ abstract class PDOConnection extends Connection
         'break_match_str' => [],
         // 自动参数绑定
         'auto_param_bind' => true,
+        // 数据库时区设置
+        'timezone'        => '',
     ];
 
     /**
@@ -586,6 +588,9 @@ public function connect(array $config = [], $linkNum = 0, $autoConnection = fals
                 $this->trigger('CONNECT:[ UseTime:' . number_format(microtime(true) - $startTime, 6) . 's ] ' . $config['dsn']);
             }
 
+            // 设置数据库时区
+            $this->setTimezone($this->links[$linkNum], $config['timezone']);
+
             $this->db->trigger('after_connect', $this->links[$linkNum]);
             return $this->links[$linkNum];
         } catch (\PDOException $e) {
@@ -2007,4 +2012,43 @@ public function commitXa(string $xid): void
     public function rollbackXa(string $xid): void
     {
     }
+
+    /**
+     * 设置数据库时区.
+     *
+     * @param PDO   $pdo       PDO实例
+     * @param string $timezone 时区名称，如 'Asia/Shanghai' 或 '+08:00'
+     *
+     * @return void
+     */
+    protected function setTimezone(PDO $pdo, string $timezone): void
+    {
+        if (empty($timezone)) {
+            return;
+        }
+
+        try {
+            $sql = $this->getSetTimezoneSql($timezone);
+            if (!empty($sql)) {
+                $pdo->exec($sql);
+            }
+        } catch (\Exception $e) {
+            // 时区设置失败，记录日志但不中断连接
+            $this->db->log('Set timezone failed: ' . $e->getMessage(), 'warning');
+        }
+    }
+
+    /**
+     * 获取设置时区的SQL语句.
+     * 子类应重写此方法以提供数据库特定的时区设置SQL.
+     *
+     * @param string $timezone 时区名称
+     *
+     * @return string
+     */
+    protected function getSetTimezoneSql(string $timezone): string
+    {
+        // 默认实现，子类应重写此方法
+        return '';
+    }
 }

src/db/connector/Mongo.php

@@ -106,6 +106,8 @@ class Mongo extends Connection
         'pk_convert_id'   => false,
         // typeMap
         'type_map'        => ['root' => 'array', 'document' => 'array'],
+        // 时区设置（MongoDB使用UTC，建议在应用层处理时区转换）
+        'timezone'        => '',
     ];
 
     /**
@@ -177,6 +179,13 @@ public function connect(array $config = [], $linkNum = 0)
                 // 记录数据库连接信息
                 $this->trigger('CONNECT:[ UseTime:' . number_format(microtime(true) - $startTime, 6) . 's ] ' . $config['dsn']);
             }
+
+            // Note: MongoDB 使用 UTC 时间存储，建议在应用层处理时区转换
+            // 时区配置 $config['timezone'] 可用于记录连接的期望时区
+            if (!empty($config['timezone'])) {
+                // 记录时区配置，但不实际设置（MongoDB 内部使用 UTC）
+                $this->db->log('Timezone setting: ' . $config['timezone'] . ' (Note: MongoDB uses UTC internally)', 'info');
+            }
         }
 
         return $this->links[$linkNum];

src/db/connector/Mysql.php

@@ -212,4 +212,16 @@ protected function restoreBufferedMode(): void
             $this->linkID->setAttribute(PDO::MYSQL_ATTR_USE_BUFFERED_QUERY, true);
         }
     }
+
+    /**
+     * 获取设置时区的SQL语句.
+     *
+     * @param string $timezone 时区名称，如 'Asia/Shanghai' 或 '+08:00'
+     *
+     * @return string
+     */
+    protected function getSetTimezoneSql(string $timezone): string
+    {
+        return "SET time_zone = '$timezone'";
+    }
 }

src/db/connector/Oracle.php

@@ -122,4 +122,16 @@ protected function supportSavepoint(): bool
     {
         return true;
     }
+
+    /**
+     * 获取设置时区的SQL语句.
+     *
+     * @param string $timezone 时区名称，如 'Asia/Shanghai' 或 '+08:00'
+     *
+     * @return string
+     */
+    protected function getSetTimezoneSql(string $timezone): string
+    {
+        return "ALTER SESSION SET TIME_ZONE = '$timezone'";
+    }
 }

src/db/connector/Pgsql.php

@@ -110,4 +110,16 @@ protected function supportSavepoint(): bool
     {
         return true;
     }
+
+    /**
+     * 获取设置时区的SQL语句.
+     *
+     * @param string $timezone 时区名称，如 'Asia/Shanghai' 或 '+08:00'
+     *
+     * @return string
+     */
+    protected function getSetTimezoneSql(string $timezone): string
+    {
+        return "SET timezone = '$timezone'";
+    }
 }

src/db/connector/Sqlite.php

@@ -94,4 +94,18 @@ protected function supportSavepoint(): bool
     {
         return true;
     }
+
+    /**
+     * 获取设置时区的SQL语句.
+     *
+     * @param string $timezone 时区名称，如 'Asia/Shanghai' 或 '+08:00'
+     *
+     * @return string SQLite 不支持时区设置，返回空字符串
+     */
+    protected function getSetTimezoneSql(string $timezone): string
+    {
+        // SQLite 是嵌入式数据库，不支持时区设置
+        // 建议在应用层处理时区转换
+        return '';
+    }
 }

src/db/connector/Sqlsrv.php

@@ -128,4 +128,18 @@ public function getTables(string $dbName = ''): array
 
         return $info;
     }
+
+    /**
+     * 获取设置时区的SQL语句.
+     *
+     * @param string $timezone 时区名称，如 'Asia/Shanghai' 或 '+08:00'
+     *
+     * @return string
+     */
+    protected function getSetTimezoneSql(string $timezone): string
+    {
+        // SQL Server 使用 SET TIME ZONE 命令
+        // 注意：SQL Server 2016 及以上版本才支持此命令
+        return "SET TIME ZONE '$timezone'";
+    }
 }