kvazar/crawler-api-node
1
0
Fork 0
mirror of https://github.com/kvazar-network/crawler-api-node.git synced 2025-01-22 12:54:22 +00:00
Code Issues Projects Releases Wiki Activity

add sqlite driver

Browse Source
This commit is contained in:
d47081 2022-07-15 11:25:36 +03:00
parent 05bfd44260
commit 2d590c7fe1
1 changed files with 50 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

73
library/mysql.php → library/sqlite.php
View File

@ -1,12 +1,14 @@
<?php <?php
class MySQL { class SQLite {
public function __construct() { private $_db;
public function __construct($database, $username, $password) {
try { try {
$this->_db = new PDO('mysql:dbname=' . DB_NAME . ';host=' . DB_HOST . ';port=' . DB_PORT . ';charset=utf8', DB_USERNAME, DB_PASSWORD, [PDO::MYSQL_ATTR_INIT_COMMAND => 'SET NAMES utf8']); $this->_db = new PDO('sqlite:' . $database, $username, $password, [PDO::MYSQL_ATTR_INIT_COMMAND => 'SET NAMES utf8']);
$this->_db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); $this->_db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
$this->_db->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC); $this->_db->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC);
$this->_db->setAttribute(PDO::ATTR_TIMEOUT, 600); $this->_db->setAttribute(PDO::ATTR_TIMEOUT, 600);
@ -38,7 +40,9 @@ class MySQL {
$query->execute([$blockId]); $query->execute([$blockId]);
return $query->rowCount() ? $query->fetch()['blockId'] : false; $result = $query->fetch();
return $result ? $result['blockId'] : false;
} catch(PDOException $e) { } catch(PDOException $e) {
trigger_error($e->getMessage()); trigger_error($e->getMessage());
@ -54,7 +58,9 @@ class MySQL {
$query->execute([$hash]); $query->execute([$hash]);
return $query->rowCount() ? $query->fetch()['nameSpaceId'] : false; $result = $query->fetch();
return $result ? $result['nameSpaceId'] : false;
} catch(PDOException $e) { } catch(PDOException $e) {
trigger_error($e->getMessage()); trigger_error($e->getMessage());
@ -70,7 +76,9 @@ class MySQL {
$query->execute([$txId]); $query->execute([$txId]);
return $query->rowCount() ? $query->fetch()['dataId'] : false; $result = $query->fetch();
return $result ? $result['dataId'] : false;
} catch(PDOException $e) { } catch(PDOException $e) {
trigger_error($e->getMessage()); trigger_error($e->getMessage());
@ -82,11 +90,10 @@ class MySQL {
try { try {
$query = $this->_db->prepare('INSERT INTO `block` SET `blockId` = ?, $query = $this->_db->prepare('INSERT INTO `block` (`blockId`, `lostTransactions`, `timeIndexed`)
`lostTransactions` = 0, VALUES (?, 0, ?)');
`timeIndexed` = UNIX_TIMESTAMP()');
$query->execute([$blockId]); $query->execute([$blockId, time()]);
return $blockId; return $blockId;
@ -116,10 +123,10 @@ class MySQL {
try { try {
$query = $this->_db->prepare('INSERT INTO `namespace` SET `hash` = ?, $query = $this->_db->prepare('INSERT INTO `namespace` (`hash`, `timeIndexed`)
`timeIndexed` = UNIX_TIMESTAMP()'); VALUES (?, ?)');
$query->execute([$hash]); $query->execute([$hash, time()]);
return $this->_db->lastInsertId(); return $this->_db->lastInsertId();
@ -133,16 +140,35 @@ class MySQL {
try { try {
$query = $this->_db->prepare('INSERT INTO `data` SET `blockId` = :blockId, $query = $this->_db->prepare('INSERT INTO `data` (
`nameSpaceId` = :nameSpaceId,
`time` = :time, `blockId`,
`size` = :size, `nameSpaceId`,
`txid` = :txid, `time`,
`key` = :key, `size`,
`value` = :value, `txid`,
`deleted` = :deleted, `key`,
`ns` = :ns, `value`,
`timeIndexed` = UNIX_TIMESTAMP()'); `deleted`,
`ns`,
`timeIndexed`
)
VALUES (
:blockId,
:nameSpaceId,
:time,
:size,
:txid,
:key,
:value,
:deleted,
:ns,
:timeIndexed
)');
$query->bindValue(':blockId', $blockId, PDO::PARAM_INT); $query->bindValue(':blockId', $blockId, PDO::PARAM_INT);
$query->bindValue(':nameSpaceId', $nameSpaceId, PDO::PARAM_INT); $query->bindValue(':nameSpaceId', $nameSpaceId, PDO::PARAM_INT);
@ -153,6 +179,7 @@ class MySQL {
$query->bindValue(':value', $value, PDO::PARAM_STR); $query->bindValue(':value', $value, PDO::PARAM_STR);
$query->bindValue(':deleted', (int) $deleted, PDO::PARAM_STR); $query->bindValue(':deleted', (int) $deleted, PDO::PARAM_STR);
$query->bindValue(':ns', (int) $ns, PDO::PARAM_STR); $query->bindValue(':ns', (int) $ns, PDO::PARAM_STR);
$query->bindValue(':timeIndexed', time(), PDO::PARAM_INT);
$query->execute(); $query->execute();