blob: f4ccd4c2feb5ae1f557b1ff96cc2ad7bcc0eccbb (
plain)
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
|
<?php
Prado::using('System.DataAccess.TDatabaseProvider');
Prado::using('System.DataAccess.creole.*');
class TCreoleProvider extends TDatabaseProvider
{
private $_connection = null;
public function getConnection()
{
if(is_null($this->_connection))
$this->_connection = new TCreoleConnection($this);
return $this->_connection;
}
public function getConnectionString()
{
if(strlen(parent::getConnectionString()) > 0)
return parent::getConnectionString();
else
return $this->generateConnectionString();
}
protected function generateConnectionString()
{
$driver = $this->getDriver();
$user = $this->getUsername();
$pass = $this->getPassword();
$host = $this->getHost();
$database = $this->getDatabase();
$pass = strlen($pass) > 0 ? ':'.$pass : '';
$username_password = strlen($user) > 0 ? $user.$pass.'@' : '';
$database = strlen($database) > 0 ? '/'.$database : '';
return "{$driver}://{$username_password}{$host}{$database}";
}
}
class TCreoleConnection extends TDbConnection
{
private $_connection = null;
protected function beginDbTransaction()
{
}
/**
* Closes the connection to the database.
*/
public function close()
{
$this->_connection->close();
}
public function prepare($statement)
{
return $this->_connection->prepareStatement($statement);
}
//public function execute($sql,
/**
* Opens a database connection with settings provided in the ConnectionString.
*/
public function open()
{
if(is_null($this->_connection))
{
$connectionString = $this->getProvider()->getConnectionString();
if(strlen($connectionString) < 1 || strcmp($connectionString,'://') === 0)
throw new TDbConnectionException('db_driver_required');
$class = 'System.DataAccess.creole.creole.Creole';
$creole = Prado::createComponent($class);
$this->_connection = $creole->getConnection($connectionString);
}
return $this->_connection;
}
}
?>
|
