/home/joan/000www/repo/spirit/1.0/core/extensions/db/adapters/pdo/access.php

Ir a la documentación de este archivo.

<?php
class DbPdoAccess extends DbPDO {

        protected $db_rbdm = "odbc";

        const TYPE_INTEGER = "INTEGER";

        const TYPE_DATE = "DATETIME";

        const TYPE_VARCHAR = "VARCHAR";

        const TYPE_DECIMAL = "DECIMAL";

        const TYPE_DATETIME = "DATETIME";

        const TYPE_CHAR = "CHAR";

        public function initialize(){
                //$this->exec("SET IDENTITY_INSERT ON");
        }

        public function table_exists($table, $schema=''){
                $table = addslashes("$table");
                $num = $this->fetch_one("SELECT COUNT(*) FROM sysobjects WHERE type = 'U' AND name = '$table'");
                return $num[0];
        }

        public function limit($sql, $number){
                if(!is_numeric($number)){
                        return $sql;
                }
                $orderby = stristr($sql, 'ORDER BY');
        if($orderby!==false){
            $sort = (stripos($orderby, 'desc') !== false) ? 'desc' : 'asc';
            $order = str_ireplace('ORDER BY', '', $orderby);
            $order = trim(preg_replace('/ASC|DESC/i', '', $order));
        }
        $sql = preg_replace('/^SELECT\s/i', 'SELECT TOP '.($number).' ', $sql);
        $sql = 'SELECT * FROM (SELECT TOP '.$number. ' * FROM ('.$sql.') AS itable';
        if($orderby !== false) {
            $sql.= ' ORDER BY '.$order.' ';
            $sql.= (stripos($sort, 'asc') !== false) ? 'DESC' : 'ASC';
        }
        $sql.= ') AS otable';
        if ($orderby!==false) {
            $sql.=' ORDER BY '.$order.' '.$sort;
        }
        return $sql;

        }

        public function drop_table($table, $if_exists=true){
                if($if_exists){
                        if($this->table_exists($table)){
                                return $this->query("DROP TABLE $table");
                        } else {
                                return true;
                        }
                } else {
                        return $this->query("DROP TABLE $table");
                }
        }

        public function create_table($table, $definition, $index=array()){
                $create_sql = "CREATE TABLE $table (";
                if(!is_array($definition)){
                        new KumbiaException("Definici&oacute;n invalida para crear la tabla '$table'");
                        return false;
                }
                $create_lines = array();
                $index = array();
                $unique_index = array();
                $primary = array();
                $not_null = "";
                $size = "";
                foreach($definition as $field => $field_def){
                        if(isset($field_def['not_null'])){
                                $not_null = $field_def['not_null'] ? 'NOT NULL' : '';
                        } else {
                                $not_null = "";
                        }
                        if(isset($field_def['size'])){
                                $size = $field_def['size'] ? '('.$field_def['size'].')' : '';
                        } else {
                                $size = "";
                        }
                        if(isset($field_def['index'])){
                                if($field_def['index']){
                                        $index[] = "INDEX($field)";
                                }
                        }
                        if(isset($field_def['unique_index'])){
                                if($field_def['unique_index']){
                                        $index[] = "UNIQUE($field)";
                                }
                        }
                        if(isset($field_def['primary'])){
                                if($field_def['primary']){
                                        $primary[] = "$field";
                                }
                        }
                        if(isset($field_def['auto'])){
                                if($field_def['auto']){
                                        $field_def['extra'] = isset($field_def['extra']) ? $field_def['extra']." IDENTITY" : "IDENTITY";
                                }
                        }
                        if(isset($field_def['extra'])){
                                $extra = $field_def['extra'];
                        } else {
                                $extra = "";
                        }
                        $create_lines[] = "$field ".$field_def['type'].$size.' '.$not_null.' '.$extra;
                }
                $create_sql.= join(',', $create_lines);
                $last_lines = array();
                if(count($primary)){
                        $last_lines[] = 'PRIMARY KEY('.join(",", $primary).')';
                }
                if(count($index)){
                        $last_lines[] = join(',', $index);
                }
                if(count($unique_index)){
                        $last_lines[] = join(',', $unique_index);
                }
                if(count($last_lines)){
                        $create_sql.= ','.join(',', $last_lines).')';
                }
                return $this->query($create_sql);

        }

        public function list_tables(){
                return $this->fetch_all("SELECT name FROM sysobjects WHERE type = 'U' ORDER BY name");
        }

        public function describe_table($table, $schema=''){
                $describe_table = $this->fetch_all("exec sp_columns @table_name = '$table'");
                $final_describe = array();
                foreach($describe_table as $field){
                        $final_describe[] = array(
                                "Field" => $field["COLUMN_NAME"],
                                "Type" => $field['LENGTH'] ? $field["TYPE_NAME"] : $field["TYPE_NAME"]."(".$field['LENGTH'].")",
                                "Null" => $field['NULLABLE'] == 1 ? "YES" : "NO"
                        );
                }
                $describe_keys = $this->fetch_all("exec sp_pkeys @table_name = '$table'");
                foreach($describe_keys as $field){
                        for($i=0;$i<=count($final_describe)-1;$i++){
                                if($final_describe[$i]['Field']==$field['COLUMN_NAME']){
                                        $final_describe[$i]['Key'] = 'PRI';
                                } else {
                                        $final_describe[$i]['Key'] = "";
                                }
                        }
                }
                return $final_describe;
        }

        public function last_insert_id($table='', $primary_key=''){
                $num = $this->fetch_one("SELECT MAX($primary_key) FROM $table");
                return (int) $num[0];
        }


}

---