|
1
|
|
|
<?php |
|
2
|
|
|
|
|
3
|
|
|
/** |
|
4
|
|
|
* Simple Machines Forum (SMF) |
|
5
|
|
|
* |
|
6
|
|
|
* @package SMF |
|
7
|
|
|
* @author Simple Machines http://www.simplemachines.org |
|
8
|
|
|
* @copyright 2017 Simple Machines and individual contributors |
|
9
|
|
|
* @license http://www.simplemachines.org/about/smf/license.php BSD |
|
10
|
|
|
* |
|
11
|
|
|
* @version 2.1 Beta 4 |
|
12
|
|
|
*/ |
|
13
|
|
|
|
|
14
|
|
|
if (!defined('SMF')) |
|
15
|
|
|
die('Hacking attempt...'); |
|
16
|
|
|
|
|
17
|
|
|
/** |
|
18
|
|
|
* PostgreSQL Cache API class |
|
19
|
|
|
* @package cacheAPI |
|
20
|
|
|
*/ |
|
21
|
|
|
class postgres_cache extends cache_api |
|
|
|
|
|
|
22
|
|
|
{ |
|
23
|
|
|
|
|
24
|
|
|
/** |
|
25
|
|
|
* @var false|resource of the pg_prepare from get_data. |
|
26
|
|
|
*/ |
|
27
|
|
|
private $pg_get_data_prep; |
|
28
|
|
|
|
|
29
|
|
|
/** |
|
30
|
|
|
* @var false|resource of the pg_prepare from put_data. |
|
31
|
|
|
*/ |
|
32
|
|
|
private $pg_put_data_prep; |
|
33
|
|
|
|
|
34
|
|
|
public function __construct() |
|
35
|
|
|
{ |
|
36
|
|
|
parent::__construct(); |
|
37
|
|
|
|
|
38
|
|
|
} |
|
39
|
|
|
|
|
40
|
|
|
/** |
|
41
|
|
|
* {@inheritDoc} |
|
42
|
|
|
*/ |
|
43
|
|
|
public function connect() |
|
44
|
|
|
{ |
|
45
|
|
|
global $db_prefix, $db_connection; |
|
46
|
|
|
|
|
47
|
|
|
pg_prepare($db_connection, '', 'SELECT 1 |
|
48
|
|
|
FROM pg_tables |
|
49
|
|
|
WHERE schemaname = $1 |
|
50
|
|
|
AND tablename = $2'); |
|
51
|
|
|
|
|
52
|
|
|
$result = pg_execute($db_connection, '', array('public', $db_prefix . 'cache')); |
|
53
|
|
|
|
|
54
|
|
|
if (pg_affected_rows($result) === 0) |
|
55
|
|
|
pg_query($db_connection, 'CREATE UNLOGGED TABLE {db_prefix}cache (key text, value text, ttl bigint, PRIMARY KEY (key))'); |
|
56
|
|
|
} |
|
57
|
|
|
|
|
58
|
|
|
/** |
|
59
|
|
|
* {@inheritDoc} |
|
60
|
|
|
*/ |
|
61
|
|
|
public function isSupported($test = false) |
|
62
|
|
|
{ |
|
63
|
|
|
global $smcFunc, $db_connection; |
|
64
|
|
|
|
|
65
|
|
|
|
|
66
|
|
|
if ($smcFunc['db_title'] !== 'PostgreSQL') |
|
67
|
|
|
return false; |
|
68
|
|
|
|
|
69
|
|
|
$result = pg_query($db_connection, 'SHOW server_version_num'); |
|
70
|
|
|
$res = pg_fetch_assoc($result); |
|
71
|
|
|
|
|
72
|
|
|
if ($res['server_version_num'] < 90500) |
|
73
|
|
|
return false; |
|
74
|
|
|
|
|
75
|
|
|
return $test ? true : parent::isSupported(); |
|
76
|
|
|
} |
|
77
|
|
|
|
|
78
|
|
|
/** |
|
79
|
|
|
* {@inheritDoc} |
|
80
|
|
|
*/ |
|
81
|
|
|
public function getData($key, $ttl = null) |
|
82
|
|
|
{ |
|
83
|
|
|
global $db_prefix, $db_connection; |
|
84
|
|
|
|
|
85
|
|
|
$ttl = time() - $ttl; |
|
86
|
|
|
|
|
87
|
|
|
if (empty($this->pg_get_data_prep)) |
|
88
|
|
|
$this->pg_get_data_prep = pg_prepare($db_connection, 'smf_cache_get_data', 'SELECT value FROM ' . $db_prefix . 'cache WHERE key = $1 AND ttl >= $2 LIMIT 1'); |
|
89
|
|
|
|
|
90
|
|
|
$result = pg_execute($db_connection, 'smf_cache_get_data', array($key, $ttl)); |
|
91
|
|
|
|
|
92
|
|
|
if (pg_affected_rows($result) === 0) |
|
93
|
|
|
return null; |
|
94
|
|
|
|
|
95
|
|
|
$res = pg_fetch_assoc($result); |
|
96
|
|
|
|
|
97
|
|
|
return $res['value']; |
|
98
|
|
|
} |
|
99
|
|
|
|
|
100
|
|
|
/** |
|
101
|
|
|
* {@inheritDoc} |
|
102
|
|
|
*/ |
|
103
|
|
|
public function putData($key, $value, $ttl = null) |
|
104
|
|
|
{ |
|
105
|
|
|
global $db_prefix, $db_connection; |
|
106
|
|
|
|
|
107
|
|
|
if (!isset($value)) |
|
108
|
|
|
$value = ''; |
|
109
|
|
|
|
|
110
|
|
|
$ttl = time() + $ttl; |
|
111
|
|
|
|
|
112
|
|
|
if (empty($this->pg_put_data_prep)) |
|
113
|
|
|
$this->pg_put_data_prep = pg_prepare($db_connection, 'smf_cache_put_data', |
|
114
|
|
|
'INSERT INTO ' . $db_prefix . 'cache(key,value,ttl) VALUES($1,$2,$3) |
|
115
|
|
|
ON CONFLICT(key) DO UPDATE SET value = excluded.value, ttl = excluded.ttl' |
|
116
|
|
|
); |
|
117
|
|
|
|
|
118
|
|
|
$result = pg_execute($db_connection, 'smf_cache_put_data', array($key, $value, $ttl)); |
|
119
|
|
|
|
|
120
|
|
|
if (pg_affected_rows($result) > 0) |
|
|
|
|
|
|
121
|
|
|
return true; |
|
122
|
|
|
else |
|
123
|
|
|
return false; |
|
124
|
|
|
} |
|
125
|
|
|
|
|
126
|
|
|
/** |
|
127
|
|
|
* {@inheritDoc} |
|
128
|
|
|
*/ |
|
129
|
|
|
public function cleanCache($type = '') |
|
130
|
|
|
{ |
|
131
|
|
|
global $smcFunc; |
|
132
|
|
|
|
|
133
|
|
|
$smcFunc['db_query']('', |
|
134
|
|
|
'TRUNCATE TABLE {db_prefix}cache', |
|
135
|
|
|
array() |
|
136
|
|
|
); |
|
137
|
|
|
|
|
138
|
|
|
return true; |
|
139
|
|
|
} |
|
140
|
|
|
} |
|
141
|
|
|
|
|
142
|
|
|
?> |
Yoshi2889 /
SMF2.1
Loading history...
This check marks property names that have not been written in camelCase.
In camelCase names are written without any punctuation, the start of each new word being marked by a capital letter. Thus the name database connection string becomes
databaseConnectionString.