Onliner Materialized

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.