| 包 | XS.util.db |
|---|---|
| 继承关系 | class XSDatabasePgSQL » XSDatabase |
| 版本 | 1.0.0 |
| 源代码 | sdk/php/util/XSDataSource.class.php |
| 名称 | 描述 | 定义于 |
|---|---|---|
| close() | 关闭数据库连接 | XSDatabasePgSQL |
| connect() | XSDatabasePgSQL | |
| query() | 执行 SQL 语句查询 | XSDatabasePgSQL |
| query1() | 查询数据库首行 | XSDatabase |
| setUtf8() | 将输出字符集设置为 UTF-8 | XSDatabasePgSQL |
|
public void close()
|
public function close()
{
if (is_resource($this->link)) {
pg_close($this->link);
$this->link = null;
}
}
关闭数据库连接
|
public void connect($param)
| ||
| $param | ||
public function connect($param)
{
$dsn = "host={$param['host']} ";
$dsn .= isset($param['port']) ? "port={$param['port']} " : '';
$dsn .= "dbname={$param['dbname']} user={$param['user']} password={$param['pass']}";
if (!($this->link = @pg_connect($dsn))) {
throw new XSException('Error connecting to PGSQL database:' . $param['dbname'] . '.');
pg_set_error_verbosity($this->link, PGSQL_ERRORS_DEFAULT);
pg_query('SET standard_conforming_strings=off');
}
}
|
public mixed query(string $query)
| ||
| $query | string | 要执行的 SQL 语句 |
| {return} | mixed | |
public function query($query)
{
//echo "[DEBUG] SQL: $sql\n";
$res = pg_query($this->link, $query);
if ($res === false) {
throw new XSException('PgSQL ERROR: ' . pg_last_error($this->link));
}
$ret = array();
while ($tmp = pg_fetch_assoc($res)) {
$ret[] = $tmp;
}
pg_free_result($res);
return $ret;
}
执行 SQL 语句查询
|
public void setUtf8()
|
public function setUtf8()
{
pg_set_client_encoding($this->link, 'UTF8');
}
将输出字符集设置为 UTF-8
| 包 | XS.util.db |
|---|---|
| 继承关系 | class XSDatabasePgSQL » XSDatabase |
| 版本 | 1.0.0 |
| 源代码 | sdk/php/util/XSDataSource.class.php |
| 名称 | 描述 | 定义于 |
|---|---|---|
| close() | 关闭数据库连接 | XSDatabasePgSQL |
| connect() | XSDatabasePgSQL | |
| query() | 执行 SQL 语句查询 | XSDatabasePgSQL |
| query1() | 查询数据库首行 | XSDatabase |
| setUtf8() | 将输出字符集设置为 UTF-8 | XSDatabasePgSQL |
|
public void close()
|
public function close()
{
if (is_resource($this->link)) {
pg_close($this->link);
$this->link = null;
}
}
关闭数据库连接
|
public void connect($param)
| ||
| $param | ||
public function connect($param)
{
$dsn = "host={$param['host']} ";
$dsn .= isset($param['port']) ? "port={$param['port']} " : '';
$dsn .= "dbname={$param['dbname']} user={$param['user']} password={$param['pass']}";
if (!($this->link = @pg_connect($dsn))) {
throw new XSException('Error connecting to PGSQL database:' . $param['dbname'] . '.');
pg_set_error_verbosity($this->link, PGSQL_ERRORS_DEFAULT);
pg_query('SET standard_conforming_strings=off');
}
}
|
public mixed query(string $query)
| ||
| $query | string | 要执行的 SQL 语句 |
| {return} | mixed | |
public function query($query)
{
//echo "[DEBUG] SQL: $sql\n";
$res = pg_query($this->link, $query);
if ($res === false) {
throw new XSException('PgSQL ERROR: ' . pg_last_error($this->link));
}
$ret = array();
while ($tmp = pg_fetch_assoc($res)) {
$ret[] = $tmp;
}
pg_free_result($res);
return $ret;
}
执行 SQL 语句查询
|
public void setUtf8()
|
public function setUtf8()
{
pg_set_client_encoding($this->link, 'UTF8');
}
将输出字符集设置为 UTF-8
留下一条评论吧!
请到论坛 登录 后刷新本页面!