<?php

class DatabaseHandler {

        /**

         * sql语句查询

         */

        public static function query_data ($dataName,$sql,$query=array()) {

            $result = array();

            if (!empty($sql)) {

                $data = Bj_PdoDB::factory($dataName)->allPrepare($sql, $query);

                if  (!$data->isEmpty()) {

                    $result = $data->data;

                }

            }

            return $result;

        }

        /**

         * 查询数据

         */

        public static function select_data ($dataName,$tableName,$where,$param=array(),$desc='') {

            $result = array();

            $query = array();

            $query_str = '1=1';

            $tmp = '';

            $str_arr = '';

            if (!empty($param)) {

                $str = '';

                foreach ($param as $val) {

                    $str .= '`'.$val.'`,';

                }

                $str = substr($str,0,-1);

            }

            $str_arr = !empty($str) ? $str : '*';

            if ( !empty($where) ) {

                foreach ($where as $key => $value) {

                    $tmp .= ' AND '.$key.'=:'.$key.'';

                    $query[':'.$key] = $value;

                }

            }

            $query_str .= $tmp;

            if (!empty($desc)) {

                $query_str .= $desc;

            }

            $sql = "SELECT {$str_arr} FROM `".$tableName."` WHERE {$query_str} ";

            $query_data = Bj_PdoDB::factory($dataName)->allPrepare($sql, $query);

            if ( !$query_data->isEmpty() ) {

                $result = $query_data->data;

            }

            return $result;

        }

        /**

         * 批量添加信息

         */

        public static function insert_data($dataName,$tableName,$add_param){

            $flag = false;

            if (!empty($add_param)) {

                $fileds = array();

                $str = '';

                foreach($add_param as $k=>$val){

                    $str .= '(';

                    $i = 0;

                    foreach ($val as $key=>$vl) {

                        $fileds[$i] = '`'.$key.'`';

                        $str .= "'".addslashes($vl)."',";

                        $i++;

                    }

                    $str = substr($str,0,-1);

                    $str .= '),';

                }

                $filed_str = implode(',',$fileds);

                $val_str = substr($str,0,-1);

                $sql = "INSERT INTO `".$tableName."` ({$filed_str}) VALUES {$val_str}";

                $ret = Bj_PdoDB::factory($dataName)->insertPrepare($sql);

                if ( !$ret->isEmpty() ) {

                        $insertId = $ret->data;

                        if($insertId > 0){

                            return $insertId;

                        }

                }

            }

            return $flag;

        }

    /**

     * 删除数据

     */

    public static function delete_data ($dataName,$tableName,$id) {

        $query = array(':id' => $id);

        $sql = "DELETE FROM ". $tableName. " WHERE `id`=:id";

        $db_res = Bj_PdoDB::factory($dataName)->simplePrepare($sql,$query);

        return $db_res->data;

    }

    /**

     * 更新数据

     */

    public static function update_data ($dataName,$tableName,$id,$array) {

        $flag = false;

        if ( !empty($array) && !empty($id)) {

            $query = array(':id' => $id);

            $up_str = '';

            foreach($array as $key=>$val) {

                $query[':'.$key] = addslashes($val);

                $up_str .= '`'.$key.'`=:'.$key.',';

            }

            $up_str = substr($up_str,0,-1);

            $sql = "UPDATE `".$tableName."` SET ".$up_str." WHERE `id`=:id";

            $db_res = Bj_PdoDB::factory($dataName)->changePrepare($sql, $query);

            $flag = true;

        }

        return $flag;

    }

    /**

     * 事务

     */

    public static function transactionHandler($dataName,$type){

        switch ($type) {

            case 'begin':

                return Bj_PdoDB::factory($dataName)->beginTransaction();

                break;

            case 'commit':

                return Bj_PdoDb::factory($dataName)->commit();

                break;

            case 'rollback':

                return Bj_PdoDb::factory($dataName)->rollback();

                break;

            default :

                exit;

        }

    }

    /**

     * curl获取数据get

     */

    public static function curl_data ($curl_url){

        if (!empty($curl_url)) {

            $ch = curl_init();

            curl_setopt($ch, CURLOPT_URL, $curl_url);

            curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);

            curl_setopt($ch, CURLOPT_HEADER, 0);

            $output = curl_exec($ch);

            curl_close($ch);

            return $output;

        }

        return false;

    }

    /**

     * curl提交数据

     */

    public static function curl_data_post ($ch_url,$param) {

        $result = array();

        if (!empty($ch_url) && !empty($param)) {

            $query_string = http_build_query($param);

            $ch = curl_init();

            curl_setopt($ch, CURLOPT_URL, $ch_url);

            curl_setopt($ch, CURLOPT_RETURNTRANSFER,1);

            curl_setopt($ch, CURLOPT_POST,1);

            curl_setopt($ch, CURLOPT_POSTFIELDS, $query_string);

            curl_setopt($ch, CURLOPT_HTTPHEADER,array("application/x-www-form-urlencoded; charset=UTF-8"));

            $output = curl_exec($ch);

            curl_close($ch);

            $result = !empty($output) ? json_decode($output,true) : array();

        }

        return $result;

    }

}