rezon73/pdo-clickhouse

Just another Slim PDO database library special for ClickHouse

1.3.7 2021-02-02 00:30 UTC

Requires

• php: >=7.4.0
• ext-odbc: *
• ext-pdo: *
• rezon73/clickhouse-php-client: ^0.1.0

Requires (Dev)

• phan/phan: ^2.2
• phpunit/phpunit: ^8
• squizlabs/php_codesniffer: 3.*

MIT

• Karen Gasparyan

• database
• sql
• pdo
• clickhouse

README

Just another PDOClickHouse database library

Installation

Use Composer

$ composer require rezon73/pdo-vertica

Usage

Examples selecting, inserting, updating and deleting data from or into users table.

require_once 'vendor/autoload.php';

$hostname = '127.0.0.1';
$port = 8123;

$pdo = new \Rezon73\PDOClickHouse\Database($hostname, $port);

// SELECT * FROM users WHERE id = ?
$selectStatement = $pdo->select()
                       ->from('users')
                       ->where('id', '=', 1234);

$stmt = $selectStatement->execute();
$data = $stmt->fetch();

// INSERT INTO users ( id , usr , pwd ) VALUES ( ? , ? , ? )
$insertStatement = $pdo->insert(array(
                           "id" =>1234,
                           "usr" => "your_username",
                           "pwd" => "your_password"
                       ))
                       ->into("users");

$insertStatement->execute();

// UPDATE users SET pwd = ? WHERE id = ?
$updateStatement = $pdo->update(array("pwd" => "your_new_password"))
                       ->table("users")
                       ->where(new Clause\Conditional("id", "=", 1234));

$affectedRows = $updateStatement->execute();

// DELETE FROM users WHERE id = ?
$deleteStatement = $pdo->delete()
                       ->from("users")
                       ->where(new Clause\Conditional("id", "=", 1234));

$affectedRows = $deleteStatement->execute();

The sqlsrv extension will fail to connect when using error mode PDOClickHouse::ERRMODE_EXCEPTION (default). To connect, you will need to explicitly pass array(PDOClickHouse::ATTR_ERRMODE => PDOClickHouse::ERRMODE_WARNING) (or PDOClickHouse::ERRMODE_SILENT) into the constructor, or override the getDefaultOptions() method when using sqlsrv.

Documentation

See DOCUMENTATION

Changelog

See CHANGELOG

License

See LICENSE