mini\Database\PDODatabase class

Documentation

PDO-based database implementation

Wraps any PDO instance with a clean, ergonomic API that makes database operations pleasant while supporting any PDO-compatible database. Fetches PDO from container lazily to ensure proper scoping.

Inheritance

Implements: mini\Database\DatabaseInterface

Properties (3)

private ?PDO $pdo
private bool $inTransaction
private WeakMap $queryMap

Methods (32)

public __construct()

Create a PDODatabase instance

private lazyPdo()

Get PDO instance (from constructor or container)

public query()

Execute a SELECT query and return a composable Query

private wrapQuery()

Wrap a PartialQuery in a Query and register the mapping

private unwrapQuery()

Get the underlying PartialQuery for a Query instance

private rawExecutor()

Get a raw query executor closure for PartialQuery

public queryOne()

Execute query and return first row only as object

public queryField()

Execute query and return first column of first row

public queryColumn()

Execute query and return first column values as array

public exec()

Execute a statement (INSERT, UPDATE, DELETE)

public lastInsertId()

Get the last inserted row ID

public tableExists()

Check if a table exists in the database

public transaction()

Execute a closure within a database transaction

public getPdo()

Get the underlying PDO instance for advanced operations

public getDialect()

Get the SQL dialect for this database connection

public quote()

Quotes a value for safe use in SQL query strings

public quoteIdentifier()

Quotes an identifier (table name, column name) for safe use in SQL

public delete()

Delete rows matching a query

public update()

Update rows matching a query

public insert()

Insert a new row into a table

public upsert()

Insert a row, or update if conflict on unique columns

private buildMySQLUpsert()

Documentation missing

private buildPostgresUpsert()

Documentation missing

private buildSqliteUpsert()

Documentation missing

private buildSqlServerUpsert()

Documentation missing

private buildOracleUpsert()

Documentation missing

public getSchema()

Get database schema as a TableInterface

private generateSchemaSqlite()

Documentation missing

private generateSchemaMySQL()

Documentation missing

private generateSchemaPostgres()

Documentation missing

private generateSchemaGeneric()

Documentation missing

public withTables()

Create a VirtualDatabase with shadowed tables

Source

src/Database/PDODatabase.php:25-849