温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

thinkphp5能够支持oracle吗

发布时间:2020-12-31 14:56:28 阅读:187 作者:小新 栏目:编程语言
PHP开发者专用服务器限时活动,0元免费领,库存有限,领完即止! 点击查看>>

小编给大家分享一下thinkphp5能够支持oracle吗,相信大部分人都还不怎么了解,因此分享这篇文章给大家参考一下,希望大家阅读完这篇文章后大有收获,下面让我们一起去了解一下吧!

首先,我们知道php是完全支持oracle的,那么作为php框架的thinkphp5也是完全可以支持oracle的。

thinkphp5如何连接oracle?

数据库:ray

表的结构:ray_user

CREATE TABLE IF NOT EXISTS ray_user (
user_id int(11) unsigned NOT NULL AUTO_INCREMENT,
user_name varchar(10NOT NULL,
user_pwd varchar(40NOT NULL,
PRIMARY KEY (user_id)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 AUTO_INCREMENT=18 ;

转存表中的数据:ray_user

INSERT INTO ray_user (user_id, user_name, user_pwd) VALUES
(1, ‘updatename’, ‘ray’),
(2, ‘testname’, ‘testpwd’),

1、mysql环境下的CURD操作

数据库配置database.php

<?php
// +----------------------------------------------------------------------
// | ThinkPHP [ WE CAN DO IT JUST THINK ]
// +----------------------------------------------------------------------
// | Copyright (c) 2006~2018 http://thinkphp.cn All rights reserved.
// +----------------------------------------------------------------------
// | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )
// +----------------------------------------------------------------------
// | Author: liu21st <liu21st@gmail.com>
// +----------------------------------------------------------------------

return [
   // 数据库类型
   'type'            => 'mysql',
   // 服务器地址
   'hostname'        => '127.0.0.1',
   // 数据库名
   'database'        => 'ray',
   // 用户名
   'username'        => 'root',
   // 密码
   'password'        => ''// 你的密码
   // 端口
   'hostport'        => '3306',
   // 连接dsn
   'dsn'             => '',
   // 数据库连接参数
   'params'          => [],
   // 数据库编码默认采用utf8
   'charset'         => 'utf8',
   // 数据库表前缀
   'prefix'          => 'ray_',
   // 数据库调试模式
   'debug'           => true,
   // 数据库部署方式:0 集中式(单一服务器),1 分布式(主从服务器)
   'deploy'          => 0,
   // 数据库读写是否分离 主从式有效
   'rw_separate'     => false,
   // 读写分离后 主服务器数量
   'master_num'      => 1,
   // 指定从服务器序号
   'slave_no'        => '',
   // 是否严格检查字段是否存在
   'fields_strict'   => true,
   // 数据集返回类型
   'resultset_type'  => 'array',
   // 自动写入时间戳字段
   'auto_timestamp'  => false,
   // 时间字段取出后的默认时间格式
   'datetime_format' => 'Y-m-d H:i:s',
   // 是否需要进行SQL性能分析
   'sql_explain'     => false,
];

控制器User.php

<?php
namespace app\index\controller;

use think\Controller;
use app\index\model\User as US;

class User extends Controller
{
public function index() {
    $obj_user new US;
    // 查找
    $data $obj_user->operateUser("find",null,"1");
    var_dump($data);
    // 更新
    $updateData = [
        'user_name' => 'updatename'
    ];
    $result $obj_user->operateUser("update",$updateData,"1");
    var_dump($result);
    // 新增
    $insertData = [
        'user_name' => 'testname',
        'user_pwd' => 'testpwd'
    ];
    $result $obj_user->operateUser("insert",$insertData);
    var_dump($result);
    // 删除
    $result $obj_user->operateUser("delete",null,'2');
    var_dump($result);
}
}

模型User.php

<?php
namespace app\index\model;

use think\Model;

class User extends Model
{
public function operateUser($directive,$data null,$user_id null) {
    if($directive == "find" && $user_id != null) {
        return User::where('user_id',$user_id)->find();
    } else if($directive == "insert" && $data != null) {
        return User::save($data) ? 1 : 0;
    } else if($directive == "update" && $data != null && $user_id != null) {
        return User::where('user_id',$user_id)->find()->save($data) ? 1 : 0;
    } else if($directive == "delete" && $user_id != null) {
        return User::where('user_id',$user_id)->delete() ? 1 : 0;
    } else {
        return null;
    }
}
}

2、oracle环境下的CURD操作

数据库配置文件database.php

<?php
// +----------------------------------------------------------------------
// | ThinkPHP [ WE CAN DO IT JUST THINK ]
// +----------------------------------------------------------------------
// | Copyright (c) 2006~2018 http://thinkphp.cn All rights reserved.
// +----------------------------------------------------------------------
// | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )
// +----------------------------------------------------------------------
// | Author: liu21st <liu21st@gmail.com>
// +----------------------------------------------------------------------

return [
   // 数据库类型
   'type'            => '\think\oracle\Connection',
   // 服务器地址
   'hostname'        => '127.0.0.1',
   // 数据库名
   'database'        => 'orcl',
   // 用户名
   'username'        => 'Scott',
   // 密码
   'password'        => ''// 你的密码
   // 端口
   'hostport'        => '1521',
   // 连接dsn
   'dsn'             => '',
   // 数据库连接参数
   'params'          => [],
   // 数据库编码默认采用utf8
   'charset'         => 'utf8',
   // 数据库表前缀
   'prefix'          => 'ray_',
   // 数据库调试模式
   'debug'           => true,
   // 数据库部署方式:0 集中式(单一服务器),1 分布式(主从服务器)
   'deploy'          => 0,
   // 数据库读写是否分离 主从式有效
   'rw_separate'     => false,
   // 读写分离后 主服务器数量
   'master_num'      => 1,
   // 指定从服务器序号
   'slave_no'        => '',
   // 是否严格检查字段是否存在
   'fields_strict'   => true,
   // 数据集返回类型
   'resultset_type'  => 'array',
   // 自动写入时间戳字段
   'auto_timestamp'  => false,
   // 时间字段取出后的默认时间格式
   'datetime_format' => 'Y-m-d H:i:s',
   // 是否需要进行SQL性能分析
   'sql_explain'     => false,
];

3、根据指定ID查询记录

由于Oracle表名和字段名均需加上双引号,故改写thinkphp\library\db\Builder.php中的parseSqlTable和parseWhereItem方法。改写完成后根据ID查询记录OK。

   ...
/**
    * 将SQL语句中的__TABLE_NAME__字符串替换成带前缀的表名(小写)
    * @access protected
    * @param string $sql sql语句
    * @return string
    */
   protected function parseSqlTable($sql)
   {
        return '"'strtoupper($this->query->parseSqlTable($sql)).'"'//// 前后加上双引号并将表明设置为大写
   }

......
     // where子单元分析
   protected function parseWhereItem($field$val$rule ''$options = [], $binds = [], $bindName null)
   {
       // 字段分析
       $key $field '"'$this->parseKey($field$optionstrue) .'"' : ''////前后加上双引号

       // 查询规则和条件
       if (!is_array($val)) {
           $val is_null($val) ? ['null'''] : ['='$val];
       }
       list($exp$value) = $val;
       ...

改写了控制器和模型层方法:

控制器Users.php

<?php
namespace app\index\controller;

use think\Controller;
use app\index\model\Users as US;

class Users extends Controller
{
    public function index() {
        // 查询
        $obj_users new US;
        $data $obj_users->operateUser("find",null,"1");
        var_dump($data);
        // 更新
        $updateData = [
            'NAME' => "updateora",
            'PWD' => "newpwd"
        ];
        $result $obj_users->operateUser("update",$updateData,"1");
        var_dump($result);
        // 插入
        $insertData = [
            'NAME' => 'testname',
            'PWD' => 'testpwd'
        ];
        $result $obj_users->operateUser("insert",$insertData);
        var_dump($result);
        // 删除
        $result $obj_users->operateUser("delete",null,'18');
        var_dump($result);
    }
}

模型Users.php

<?php
namespace app\index\model;

use think\Model;

class Users extends Model
{
    public function operateUser($directive,$data null,$ID null) {
        if($directive == "find" && $ID != null) {
            return Users::where('ID',$ID)->find();
        } else if($directive == "insert" && $data != null) {
            /*$id = Users::getLastInsID('SEQUSERS')-2;
            var_dump($id);
            $data['ID'] = $id;*/
            return Users::save($data,[],'SEQUSERS') ? 1 : 0// 注意这里传参
        } else if($directive == "update" && $data != null && $ID != null) {
            return Users::where('ID',$ID)->find()->save($data) ? 1 : 0;
        } else if($directive == "delete" && $ID != null) {
            return Users::where('ID',$ID)->delete() ? 1 : 0;
        } else {
            return null;
        }
    }
}

经测试更新数据通过,接下来是最为头疼的新增。因为MySQL主键自增通过给PK添加A-I属性即可,而Oracle则需要通过触发器来实现。下面采用了简单的实现方法。

触发器,序列实现Oracle主键自增。

CREATE OR REPLACE TRIGGER TRIUSERS BEFORE
INSERT ON SCOTT.USERS FOR EACH ROW
WHEN (
new.id is null
      )
begin
select SEQUSERS.nextval into:new.id from dual;
end;

create sequence SEQUSERS
minvalue 1
maxvalue 999999999999999999999999999
start with 1
increment by 1
nocache;

需要改写think-oracle\src\Connection.php里面的getLastInsId()方法

/**
     * 获取最近插入的ID
     * @access public
     * @param string  $sequence     自增序列名
     * @return string
     */
    public function getLastInsID($sequence null)
    {
        $pdo    $this->linkID->query("select {$sequence}.nextval as id from dual");
        $pdo    $this->linkID->query("select {$sequence}.currval as id from dual");
        $result $pdo->fetchColumn();
        $pdo    $this->linkID->query("alter sequence {$sequence} increment by -1");
        $pdo    $this->linkID->query("select {$sequence}.nextval as id from dual");
        $pdo    $this->linkID->query("alter sequence {$sequence} increment by 1");
        return $result;
    }

以上是“thinkphp5能够支持oracle吗”这篇文章的所有内容,感谢各位的阅读!相信大家都有了一定的了解,希望分享的内容对大家有所帮助,如果还想学习更多知识,欢迎关注亿速云行业资讯频道!

亿速云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>

向AI问一下细节

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

AI

开发者交流群×