onliner/materialized

PHP abstraction level for Materialized database

v0.1.1 2022-12-13 11:28 UTC

Requires

• php: ^7.2 || ^8.0
• ext-pdo: *
• psr/log: ^1.1 || ^2.0

Requires (Dev)

• phpstan/phpstan: ^1.8
• phpunit/phpunit: ^8.5 || ^9.0

MIT

• pdo
• materialized
• cdc

README

Materialize DB integration layer.

Installation

The preferred way to install this extension is through composer.

Either run

composer require onliner/materialized:^0.0.1

or add this code line to the require section of your composer.json file:

"onliner/materialized": "^0.0.1"

Usage

use Onliner\Materialized\Connection;
use Onliner\Materialized\Statement\CreateConnection;
use Onliner\Materialized\Statement\CreateSource;

$connection = Connection::open('pgsl://localhost:6575');

$connection->execute(CreateConnection::kafka('kafka', 'redpanda:9092'));
$connection->execute(CreateSource::kafka('my_source', 'kafka', 'my_topic'));

// Just work with any other PDOStatement
$statement = $connection->fetch('SELECT * FROM my_source');

License

Released under the MIT license.