YII2.0 数据库增删改查

/*==================== dkhBaseModel 数据库增删改查方法 start ================================*/
    //新增一条数据
    public function baseInsertData($data){
        if(!is_array($data)) {return $this->setError([‘errmsg‘=>‘data Error‘]);};
        $db = \Yii::$app->db;
        $ok = $db->createCommand()->insert($this->tableName(), $data)->execute();
        if($ok){
            //返回自增id
            return $db->getLastInsertID();
        }else{
            return $this->setError([‘errmsg‘=>‘插入记录失败‘]);
        }
    }

    //通过条件查询一条记录
    public function baseGetOne($condition = [],$orderBy = ‘id DESC‘,$select = array()){
        //$condition 搜索条件 如：$condition = [‘and‘];$condition[] = [‘=‘,‘id‘,1];$condition[] = [‘LIKE‘,‘name‘,‘dkh‘];
        //$select 字段过滤 如： [‘id‘,‘field1‘,‘field2‘]
        return $this->find()->select($select)->where($condition)->orderBy($orderBy)->asArray()->one();
    }

    //通过条件查询一条关联模型记录
    public function baseGetOneRelation($condition = [],$tables,$orderBy = ‘‘,$select = array()){
        return $this->find()->joinWith($tables)->select($select)->where($condition)->orderBy($orderBy)->asArray()->one();
    }

    //获取全部数据
    public function baseGetAll($condition = [],$orderBy = ‘id DESC‘,$select = array()){
        return $this->find()->select($select)->where($condition)->orderBy($orderBy)->asArray()->all();
    }

    //通过条件查询多条关联模型记录
    public function baseGetAllRelation($condition = [],$tables,$orderBy = ‘‘,$select = array()){
        return $this->find()->joinWith($tables)->select($select)->where($condition)->orderBy($orderBy)->asArray()->all();
    }

    //根据id删除一条数据
    public function baseDeleteById($id){
        $this->id = $id;
        return $this->findOne($id)->delete();

    }

    //删除指定条件的数据
    public function baseDeleteAll($condition = []){
        if(empty($condition)) {return $this->setError([‘errmsg‘=>‘deleteAll Error‘]);};
        return $this->deleteAll($condition);
    }

    //执行原生sql语句，一般用于更新，批量新增，删除数据
    public function baseExecuteSql($sql){
        $db = \Yii::$app->db;
        //在调用的地方做执行是否成功的判断
        return $db->createCommand($sql)->execute();
    }

    //执行原生sql语句，一般用于查询数据 返回单行
    public function baseQueryOneSql($sql){
        $db = \Yii::$app->db;
        return $db->createCommand($sql)->queryOne();
    }

    //执行原生sql语句，一般用于查询数据 返回多行
    public function baseQueryAllSql($sql){
        $db = \Yii::$app->db;
        return $db->createCommand($sql)->queryAll();
    }

    //通过主键查询一条记录
    public function baseGetOneByid($id){
        $model =  $this->findOne($id);
        if($model){
            return $model->attributes;
        }else{
            return array();
        }
    }

    //更新符合条件的数据
    public function baseUpdateData($data,$condition = []){
        if(empty($condition)) {return $this->setError([‘errmsg‘=>‘condition Empty‘]);};
        $res = $this->updateAll($data,$condition);
        if($res === false){
            return $this->setError([‘errmsg‘=>‘更新失败‘]);
        }
        return $res;
    }

    //获取分页数据
    public function basePageData($condition = [],$page,$pageSize,$orderBy = ‘id DESC‘,$select = array()){
        //$page,$pageSize   相当于 LIMIT $page,$pageSize
        //$select 过滤字段 [‘id‘,‘field1‘,‘field2‘]
        return $this->find()->select($select)->where($condition)->offset($page)->limit($pageSize)->orderBy($orderBy)->asArray()->all();
    }

    //获取分页数据 并且 关联模型记录
    public function basePageDataRelation($condition = [],$page,$pageSize,$tables,$orderBy = ‘‘,$select = array()){
        //$page,$pageSize  相当于SQL语句 LIMIT $page,$pageSize
        //$select 字段过滤 如： [‘id‘,‘field1‘,‘field2‘]
        //$tables 关联模型表 如： [‘table1‘,‘table2‘]
        return $this->find()->joinWith($tables)->select($select)->where($condition)->orderBy($orderBy)->offset($page)->limit($pageSize)->asArray()->all();
    }

    //通过条件查询记录条数
    public function baseGetCount($condition = [],$select = array()){
        return $this->find()->select($select)->where($condition)->count();
    }

    //通过条件查询记录条数 并且 关联模型
    public function baseGetCountRelation($condition = [],$tables,$select = array()){
        return $this->find()->joinWith($tables)->select($select)->where($condition)->count();
    }

    //通过条件查询一条记录
    public function baseModelGetOne($params){
        if(isset($params[‘condition‘]) && is_array($params[‘condition‘]) && !empty($params[‘condition‘])){
            $condition = $params[‘condition‘];
        }else{
            $condition = [];
        }
        if(isset($params[‘field‘]) && is_array($params[‘field‘]) && !empty($params[‘field‘])){
            $field = $params[‘field‘];
        }else{
            $field = [];
        }
        if(isset($params[‘order‘])  && !empty($params[‘order‘])){
            $order = $params[‘order‘];
        }else{
            $order = ‘id DESC‘;
        }
        return $this->find()->select($field)->where($condition)->orderBy($order)->asArray()->one();
    }

    //通过条件查询一条关联模型记录
    public function baseModelGetOneRelation($params){
        if(isset($params[‘condition‘]) && is_array($params[‘condition‘]) && !empty($params[‘condition‘])){
            $condition = $params[‘condition‘];
        }else{
            $condition = [];
        }
        if(isset($params[‘field‘]) && is_array($params[‘field‘]) && !empty($params[‘field‘])){
            $field = $params[‘field‘];
        }else{
            $field = [];
        }
        if(isset($params[‘order‘])  && !empty($params[‘order‘])){
            $order = $params[‘order‘];
        }else{
            $order = ‘id DESC‘;
        }
        if(isset($params[‘join‘]) && is_array($params[‘join‘])  && !empty($params[‘join‘])){
            $join = $params[‘join‘];
        }else{
            $join = ‘‘;
        }
        return $this->find()->joinWith($join)->select($field)->where($condition)->orderBy($order)->asArray()->one();
    }

    //获取全部数据
    public function baseModelGetAll($params){
        if(isset($params[‘condition‘]) && is_array($params[‘condition‘]) && !empty($params[‘condition‘])){
            $condition = $params[‘condition‘];
        }else{
            $condition = [];
        }
        if(isset($params[‘field‘]) && is_array($params[‘field‘]) && !empty($params[‘field‘])){
            $field = $params[‘field‘];
        }else{
            $field = [];
        }
        if(isset($params[‘order‘])  && !empty($params[‘order‘])){
            $order = $params[‘order‘];
        }else{
            $order = ‘id DESC‘;
        }
        return $this->find()->select($field)->where($condition)->orderBy($order)->asArray()->all();
    }

    //通过条件查询多条关联模型记录
    public function baseModelGetAllRelation($params){
        if(isset($params[‘condition‘]) && is_array($params[‘condition‘]) && !empty($params[‘condition‘])){
            $condition = $params[‘condition‘];
        }else{
            $condition = [];
        }
        if(isset($params[‘field‘]) && is_array($params[‘field‘]) && !empty($params[‘field‘])){
            $field = $params[‘field‘];
        }else{
            $field = [];
        }
        if(isset($params[‘order‘])  && !empty($params[‘order‘])){
            $order = $params[‘order‘];
        }else{
            $order = ‘id DESC‘;
        }
        if(isset($params[‘join‘]) && is_array($params[‘join‘])  && !empty($params[‘join‘])){
            $join = $params[‘join‘];
        }else{
            $join = ‘‘;
        }
        return $this->find()->joinWith($join)->select($field)->where($condition)->orderBy($order)->asArray()->all();
    }

    //获取分页数据
    public function baseModelPageData($params){
        if(isset($params[‘condition‘]) && is_array($params[‘condition‘]) && !empty($params[‘condition‘])){
            $condition = $params[‘condition‘];
        }else{
            $condition = [];
        }
        if(isset($params[‘field‘]) && is_array($params[‘field‘]) && !empty($params[‘field‘])){
            $field = $params[‘field‘];
        }else{
            $field = [];
        }
        if(isset($params[‘order‘])  && !empty($params[‘order‘])){
            $order = $params[‘order‘];
        }else{
            $order = ‘id DESC‘;
        }
        if(isset($params[‘page‘])){
            $page = $params[‘page‘];
        }else{
            $page = 0;
        }
        if(isset($params[‘pageSize‘])){
            $pageSize = $params[‘pageSize‘];
        }else{
            $pageSize = 10;
        }
        return $this->find()->select($field)->where($condition)->offset($page)->limit($pageSize)->orderBy($order)->asArray()->all();
    }

    //获取分页数据 并且 关联模型记录
    public function baseModelPageDataRelation($params){
        if(isset($params[‘condition‘]) && is_array($params[‘condition‘]) && !empty($params[‘condition‘])){
            $condition = $params[‘condition‘];
        }else{
            $condition = [];
        }
        if(isset($params[‘field‘]) && is_array($params[‘field‘]) && !empty($params[‘field‘])){
            $field = $params[‘field‘];
        }else{
            $field = [];
        }
        if(isset($params[‘order‘])  && !empty($params[‘order‘])){
            $order = $params[‘order‘];
        }else{
            $order = ‘id DESC‘;
        }
        if(isset($params[‘join‘]) && is_array($params[‘join‘])  && !empty($params[‘join‘])){
            $join = $params[‘join‘];
        }else{
            $join = ‘‘;
        }
        if(isset($params[‘page‘])){
            $page = $params[‘page‘];
        }else{
            $page = 0;
        }
        if(isset($params[‘pageSize‘])){
            $pageSize = $params[‘pageSize‘];
        }else{
            $pageSize = 10;
        }
        return $this->find()->joinWith($join)->select($field)->where($condition)->orderBy($order)->offset($page)->limit($pageSize)->asArray()->all();
    }

    //通过条件查询记录条数
    public function baseModelGetCount($params){
        if(isset($params[‘condition‘]) && is_array($params[‘condition‘]) && !empty($params[‘condition‘])){
            $condition = $params[‘condition‘];
        }else{
            $condition = [];
        }
        if(isset($params[‘field‘]) && is_array($params[‘field‘]) && !empty($params[‘field‘])){
            $field = $params[‘field‘];
        }else{
            $field = [];
        }
        return $this->find()->select($field)->where($condition)->count();
    }

    //通过条件查询记录条数 并且 关联模型
    public function baseModelGetCountRelation($params){
        if(isset($params[‘condition‘]) && is_array($params[‘condition‘]) && !empty($params[‘condition‘])){
            $condition = $params[‘condition‘];
        }else{
            $condition = [];
        }
        if(isset($params[‘field‘]) && is_array($params[‘field‘]) && !empty($params[‘field‘])){
            $field = $params[‘field‘];
        }else{
            $field = [];
        }
        if(isset($params[‘join‘]) && is_array($params[‘join‘])  && !empty($params[‘join‘])){
            $join = $params[‘join‘];
        }else{
            $join = ‘‘;
        }
        return $this->find()->joinWith($join)->select($field)->where($condition)->count();
    }

    //删除指定条件的数据
    public function baseModelDeleteAll($params){
        if(empty($params[‘condition‘])) {return $this->setError([‘errmsg‘=>‘deleteAll Error‘]);};
        return $this->deleteAll($params[‘condition‘]);
    }

    //更新符合条件的数据
    public function baseModelUpdateData($params){
        if(empty($params[‘condition‘])) {return $this->setError([‘errmsg‘=>‘condition is Empty‘]);};
        $res = $this->updateAll($params[‘data‘],$params[‘condition‘]);
        if($res === false){
            return $this->setError([‘errmsg‘=>‘更新失败‘]);
        }
        return $res;
    }

增删改查使用方法：

                //选择分组
                $condition = [‘and‘];
                $condition[] = [‘=‘,‘member.shop_id‘,$params[‘shop_id‘]];
                $condition[] = [‘IN‘,‘member.member_group_id‘,$params[‘member_tag‘][‘groups‘]];　　//索引数组
                $wshMemberModel = new WshMember();
                $memberList = $wshMemberModel->baseGetAllRelation($condition,[‘wxUserInfos‘],‘member.id DESC‘,[‘member.id‘]);

$wshWxUsersModel = new WshWxUsers();
                $userList = $wshWxUsersModel->baseGetAll([‘shop_id‘=>$params[‘shop_id‘],‘user_id‘=>$uid],‘id DESC‘,[‘user_id‘,‘open_id‘]);

$insertData = [
            ‘material_id‘=>isset($params[‘material_id‘])?$params[‘material_id‘]:0,
            ‘shop_id‘=>$params[‘shop_id‘],
            ‘shop_sub_id‘=>$_SESSION[‘_staff‘][‘shop_sub_id‘],
            ‘send_time‘=>$now,
            ‘send_type‘=>$params[‘send_type‘],
            ‘text_content‘=>$params[‘text_content‘],
            ‘sort_content‘=>$params[‘sort_content‘],
        ];

        $insertId = $wshWxMessageSendMutilModel->baseInsertData($insertData);

            $dkhWxMessageMemberMutilModel = new DkhWxMessageMemberMutil();
            $successValues = ‘‘;$successSql = ‘‘;
            //组装sql语句
            foreach($successList as $item){
                $successValues .= "(‘{$insertId}‘,‘{$item[‘user_id‘]}‘,‘1‘,‘{$now}‘,‘{$now}‘),";
            }
            if(!empty($successValues)) {
                $successSql = "INSERT INTO `dkh_wx_message_member_mutil` (`send_id`,`user_id`,`send_result`,`created`,`modified`) VALUES " . substr($successValues, 0, -1) . ‘;‘;
                //插入发送成功数据
                $dkhWxMessageMemberMutilModel->baseExecuteSql($successSql);
            }

            //消费减余额
            $balance = $balanceData[‘balance‘] - $data[‘balance‘];
            $map = [‘and‘];
            $map[] = [‘=‘, ‘member_id‘, $orderData[‘member_id‘]];
            $map[] = [‘>=‘, ‘balance‘, $data[‘balance‘]];
            $balanceOk = $dkhMemberExtendModel->baseUpdateData([‘balance‘ => $balance], $map);

            //首充 ，可参加充值赠送活动
            $condition = [‘and‘];
            $condition[] = [‘=‘, ‘dkh_recharge_activity.shop_id‘, $data[‘shop_id‘]];
            $condition[] = [‘=‘, ‘dkh_recharge_activity.is_del‘, 0];
            $condition[] = [‘=‘, ‘dkh_recharge_activity.status‘, 1];
            $condition[] = [‘<=‘, ‘dkh_recharge_activity.start_time‘, $now];
            $condition[] = [‘>=‘, ‘dkh_recharge_activity.end_time‘, $now];
            $dkhRechargeActivity = new DkhRechargeActivity();
            $rechargeActivityData = $dkhRechargeActivity->baseGetOneRelation($condition, [‘dkhRechargeActivityRelation‘], ‘dkh_recharge_activity.id DESC‘);
时间： 2024-10-10 13:15:52

YII2.0 数据库增删改查的相关文章

Yii2.0高级框架数据库增删改查的一些操作（转）

yii2.0框架是PHP开发的一个比较高效率的框架,集合了作者的大量心血,下面通过用户为例给大家详解yii2.0高级框架数据库增删改查的一些操作 ----------------------------------------------------------------------------------------------------- User::find()->all();    //返回所有用户数据:User::findOne($id);   //返回 主键 id=1  的一条数

Yii2.0高级框架数据库增删改查的一些操作

yii2.0框架是PHP开发的一个比较高效率的框架,集合了作者的大量心血,下面通过用户为例给大家详解yii2.0高级框架数据库增删改查的一些操作 ----------------------------------------------------------------------------------------------------- User::find()->all();    //返回所有用户数据:User::findOne($id);   //返回 主键 id=1  的一条数

【Android】Sqlite数据库增删改查

Android系统内置一个Sqlite数据库,如果app需要使用Sqlite数据库数据库存储数据,Android会为此app生成一个.db文件.这个数据库在data/data/<package_name>/databases里面,其中<package_name>为该安卓app的工程包名,这个目录必须root后才能看到.在Windows,单机的应用程序,存储数据,基本放到一个文件里面,正如游戏的存档,基本就是把当前的游戏状态存到一个用户很难找到的文件里面.每次存档读档就是一个从这个存

(转)SQLite数据库增删改查操作

原文:http://www.cnblogs.com/linjiqin/archive/2011/05/26/2059182.html SQLite数据库增删改查操作 一.使用嵌入式关系型SQLite数据库存储数据 在Android平台上,集成了一个嵌入式关系型数据库--SQLite,SQLite3支持NULL.INTEGER.REAL(浮点数字).TEXT(字符串文本)和BLOB(二进制对象)数据类型,虽然它支持的类型只有五种,但实际上sqlite3也接受varchar(n).char(n).d

MVC——数据库增删改查

MVC: V(View) :视图→就是页面的模板 C(Control): 控制器→客户主要面对的就是控制器, M(Model):模板→在模板里面主要就是写关于数据库的各种增删改查的方法 它们之间的关系就是→ 在控制器里调用模板里的方法,然后把得到的数据传到视图里,视图就会把得到的数据添加到自己的页面上,在通过视图里反馈的值传到控制器上.以实现对数据库的操作和控制器页面的显示.(大概是这样) 下面是对数据库增删改查的代码 一.各种数据库操作的方法(增删改查) namespace 数据库增删改查.M

Java+MyEclipse+Tomcat (六)详解Servlet和DAO数据库增删改查操作

此篇文章主要讲述DAO.Java Bean和Servlet实现操作数据库,把链接数据库.数据库操作.前端界面显示分模块化实现.其中包括数据的CRUD增删改查操作,并通过一个常用的JSP网站前端模板界面进行描述.参考前文: Java+MyEclipse+Tomcat (一)配置过程及jsp网站开发入门 Java+MyEclipse+Tomcat (二)配置Servlet及简单实现表单提交 Java+MyEclipse+Tomcat (三)配置MySQL及查询数据显示在JSP网页中 Java+MyE

Android中内容提供者ContentProvider实现数据库增删改查

1.我们首先new一个我们自己的类集成ContentProvider,并实现方法如下 package com.wzw.sqllitedemo.providers; import com.wzw.sqllitedemo.db.PersonSQLiteOpenHelper; import android.content.ContentProvider; import android.content.ContentUris; import android.content.ContentValues;

Java连接MySQL数据库增删改查通用方法

Java连接MySQL数据库增删改查通用方法 运行环境:eclipse+MySQL 以前我们Java连接MySQL数据库都是一个数据库写一个类,类下面写好多方法,要是多个数据库,就要写多个类多个方法,导致代码编写太过于繁琐,所以为了改变这样的繁琐,我将连接数据库的方法进行了一系列的封装,使用户传入一个对象值Object就可以得到想要的. 我在之前写过一篇普通的Java连接MySQL数据库,大家可以看看,以便对比参考之后就知道差距了  数据库--MySQL-->Java篇 接下来我给大家讲讲如何将

go——beego的数据库增删改查

一直都不理解使用go语言的时候,为什么还要自己去装beego,以为使用go便可以解决所有的问题,结果在朋友的点拨下,才意识到: go与beego的关系就好比是nodejs与thinkjs的关系,因此也就不怎么存在疑问为什么还要继续安装beego来完成项目运行了,beego其实就是一个快速开发Go应用的http框架,go 语言方面技术大牛,可以用来快速开发API.Web.后端服务等各种应用,是一个RESTFul的框架.再次附上beego的官网(http://beego.me/docs/intro/