crate / crate-dbal

examples/objects.php

<?php

/*
 * Basic example program about handling CrateDB OBJECTs with Doctrine DBAL.
 * https://github.com/crate/crate-dbal
 */
require __DIR__ . '/../vendor/autoload.php';

use Crate\DBAL\Driver\PDOCrate\Driver as CrateDBDriver;
use Crate\DBAL\Types\MapType;
use Doctrine\DBAL\DriverManager;
use Doctrine\DBAL\Exception\TableNotFoundException;
use Doctrine\DBAL\Schema\Column;
use Doctrine\DBAL\Schema\Table;

use Doctrine\DBAL\Tools\DsnParser;
use Doctrine\DBAL\Types\Type;


// Register driver and select platform.
// Because DBAL can't connect to the database to determine its version dynamically,
// it is the obligation of the user to provide the CrateDB version number.
// Remark: Please let us know if you find a way how to set up more ergonomically.
// https://www.doctrine-project.org/projects/doctrine-dbal/en/3.10/reference/platforms.html
$driver = new CrateDBDriver();
$dsnParser = new DsnParser(["crate" => $driver::class]);
$driver->createDatabasePlatformForVersion('6.0.0');

// Create connection options from data source URL.
$options = $dsnParser->parse('crate://crate:crate@localhost:4200/');

// Connect to database.
$connection = DriverManager::getConnection($options);

// Define table schema.
$table = new Table('example');
$objDefinition = array(
    'type' => MapType::STRICT,
    'fields' => array(
        new Column('id', Type::getType('integer'), array()),
        new Column('name', Type::getType('string'), array()),
    ),
);
$table->addColumn(
    'data',
    MapType::NAME,
    array('platformOptions' => $objDefinition),
);

// Provision database table.
$schemaManager = $connection->createSchemaManager();
try {
    $schemaManager->dropTable($table->getName());
} catch (TableNotFoundException) {

Consider adding a comment why this CATCH block is empty.

}
$schemaManager->createTable($table);

// Insert data.
$connection->insert('example', array('data' => array('id' => 42, 'name' => 'foo')), array('data' => 'map'));
$connection->insert('example', array('data' => array('id' => 43, 'name' => 'bar')), array('data' => 'map'));
$connection->executeStatement('REFRESH TABLE example');

// Query data.
$result = $connection->executeQuery('SELECT * FROM example');
print_r($result->fetchAllAssociative());

?>