array object

w

 

 

object(stdClass)#3 (8) {
}
object(stdClass)#2 (8) {
}
array(8) {
}
array(8) {
}

class extendPDO extends PDO
{
    public function newInsert($table, $insert, $field, $inputType = 'Object')
    {
        if ($inputType = 'Object') {
//bug-filter
            $insertStr = $this->objORArrTOStr($insert, $separator = ',', $symmetrySeparator = '"');
            $insertStr = $this->delEndCharacters($insertStr);

            $fieldStr = $this->objORArrTOStr($field, $separator = ',', $symmetrySeparator = '');
            $fieldStr = $this->delEndCharacters($fieldStr);

            $sql = 'INSERT INTO ' . $table . ' (' . $fieldStr . ') VALUES (' . $insertStr . ')';
            $this->query($sql);
        }
    }


    public function newUpdate($table, $newValueSet, $fieldSet, $whereStr)
    {
        var_dump($fieldSet);

        var_dump($newValueSet);

        //for object
        $newValueSet = (array)$newValueSet;
        $fieldSet = (array)$fieldSet;
        var_dump($fieldSet);

        var_dump($newValueSet);

        if (count($newValueSet) == count($fieldSet)) {
            $sql_set = '';
            foreach ($newValueSet as $key => $val) {
                $sql_set .= $fieldSet[$key] . '="' . $newValueSet[$key] . '",';

            }
            $sql_set = $this->delEndCharacters($sql_set);
            $sql = 'UPDATE ' . $table . ' SET ' . $sql_set . $whereStr;
            var_dump($sql);
            die();
            return $this->query($sql);
        }
        return false;
    }

    private function  delEndCharacters($inputStr, $CharactersNum = 1)
    {
        if (strlen($inputStr) > $CharactersNum) {
            $res = substr($inputStr, 0, strlen($inputStr) - $CharactersNum);
            return $res;
        }
        return;
    }

    private function  objORArrTOStr($input, $separator = ',', $symmetrySeparator = '"')
    {
        if (!empty($input)) {
            $str = '';
            foreach ($input as $val) {
                $str .= $symmetrySeparator . $val . $symmetrySeparator . $separator;
            }
            return $str;
        }
        return;
    }

    public function filterRequest($request)
    {
        return $request;
    }

    public function fetchRows($sql)
    {
        $rows = array();
        foreach ($this->query($sql) as $row) {
            $rows[] = $row;
        }
        return $rows;
    }

}


$extendPDO_db0 = new extendPDO('mysql:host=' . $CONF_DB['apiamz']['host'] . ';dbname=' . $CONF_DB['apiamz']['dbs']['apiamz0'], $CONF_DB['apiamz']['user'], $CONF_DB['apiamz']['passwd']);