Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- <?php
- function connect($dsn) {
- try { $pdo = new \PDO($dsn); }
- catch (\PDOException $e) { die('PDO: ' . $e->getMessage() . PHP_EOL); }
- return $pdo;
- }
- function doQuery($pdo, $sql) {
- if ( ($result = $pdo->query($sql)) === false) {
- echo "'$sql' failed: " . print_r($pdo->errorInfo(), true) . PHP_EOL;
- }
- return $result;
- }
- function create($pdo) {
- doQuery($pdo, 'DROP TABLE IF EXISTS public.foo');
- doQuery($pdo, 'CREATE TABLE public.foo ( ii int )');
- doQuery($pdo, 'INSERT INTO public.foo VALUES (42)');
- }
- $pgo = connect('pgsql:host=localhost;dbname=postgres');
- $sqo = connect('sqlite::memory:');
- doQuery($sqo, "ATTACH DATABASE ':memory:' AS public;") or die();
- create($pgo);
- create($sqo);
- $pgResult = doQuery($pgo, 'SELECT COUNT(ii) FROM foo');
- echo 'Postgres: ';
- var_dump($pgResult->fetchColumn());
- $ltResult = doQuery($sqo, 'SELECT COUNT(ii) FROM foo');
- echo 'Sqlite3: ';
- var_dump($ltResult->fetchColumn());
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement