/var/www/(Del)gepgroup.hk/php-activerecord/lib/adapters/MysqlAdapter.php


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
<?php
/**
 * @package ActiveRecord
 */
namespace ActiveRecord;

/**
 * Adapter for MySQL.
 *
 * @package ActiveRecord
 */
class MysqlAdapter extends Connection
{
    static 
$DEFAULT_PORT 3306;

    public function 
limit($sql$offset$limit)
    {
        
$offset is_null($offset) ? '' intval($offset) . ',';
        
$limit intval($limit);
        return 
"$sql LIMIT {$offset}$limit";
    }

    public function 
query_column_info($table)
    {
        return 
$this->query("SHOW COLUMNS FROM $table");
    }

    public function 
query_for_tables()
    {
        return 
$this->query('SHOW TABLES');
    }

    public function 
create_column(&$column)
    {
        
$c = new Column();
        
$c->inflected_name    Inflector::instance()->variablize($column['field']);
        
$c->name            $column['field'];
        
$c->nullable        = ($column['null'] === 'YES' true false);
        
$c->pk                = ($column['key'] === 'PRI' true false);
        
$c->auto_increment    = ($column['extra'] === 'auto_increment' true false);

        if (
$column['type'] == 'timestamp' || $column['type'] == 'datetime')
        {
            
$c->raw_type 'datetime';
            
$c->length 19;
        }
        elseif (
$column['type'] == 'date')
        {
            
$c->raw_type 'date';
            
$c->length 10;
        }
        elseif (
$column['type'] == 'time')
        {
            
$c->raw_type 'time';
            
$c->length 8;
        }
        else
        {
            
preg_match('/^([A-Za-z0-9_]+)(\(([0-9]+(,[0-9]+)?)\))?/',$column['type'],$matches);

            
$c->raw_type = (count($matches) > $matches[1] : $column['type']);

            if (
count($matches) >= 4)
                
$c->length intval($matches[3]);
        }

        
$c->map_raw_type();
        
$c->default $c->cast($column['default'],$this);

        return 
$c;
    }

    public function 
set_encoding($charset)
    {
        
$params = array($charset);
        
$this->query('SET NAMES ?',$params);
    }

    public function 
accepts_limit_and_order_for_update_and_delete() { return true; }

    public function 
native_database_types()
    {
        return array(
            
'primary_key' => 'int(11) UNSIGNED DEFAULT NULL auto_increment PRIMARY KEY',
            
'string' => array('name' => 'varchar''length' => 255),
            
'text' => array('name' => 'text'),
            
'integer' => array('name' => 'int''length' => 11),
            
'float' => array('name' => 'float'),
            
'datetime' => array('name' => 'datetime'),
            
'timestamp' => array('name' => 'datetime'),
            
'time' => array('name' => 'time'),
            
'date' => array('name' => 'date'),
            
'binary' => array('name' => 'blob'),
            
'boolean' => array('name' => 'tinyint''length' => 1)
        );
    }

}
?>