Primordyx Framework Documentation

SqlProcessor

in package

• Primordyx

Class SqlProcessor

// Simple usage with default connection
$processor = new SqlProcessor();
$processor->run('/app/database/migrations/001_create_users.sql');

// Run multiple files with wildcard
$processor = new SqlProcessor();
$processor->runAll('/app/migrations/*.sql');

// Execute SQL string directly
$sql = "CREATE TABLE users (id INT PRIMARY KEY); CREATE INDEX idx_users ON users(id);";
$processor->runSqlString($sql);

// Custom PDO connection with dry run
$pdo = new PDO($dsn, $user, $pass);
$processor = new SqlProcessor($pdo);
$processor->dryRun(true)
          ->logTo('/tmp/test.log')
          ->run('/app/migrations/test.sql');

// Error handling
$result = $processor->run('/app/migrations/001_create_tables.sql');
if (!$result) {
    // Error was fired via EventManager
    echo "Migration failed - check events\n";
}

Tags

since

1.0.0

see

EventManager

For error event handling

see

ConnectionManager

For database connection handling

Table of Contents

Properties

$logtext  : string

$db  : PDO

$dryRun  : bool

$logFile  : string|null

Methods

__construct()  : mixed

SqlProcessor constructor.

dryRun()  : static

Enables or disables dry run mode.

logTo()  : static

Configures logging output to a specified file.

run()  : bool

Loads and executes SQL statements from a specific file.

runAll()  : bool

Loads and executes all SQL files matching a wildcard pattern.

runSqlString()  : bool

Executes SQL statements from a string.

log()  : void

Internal logging method.

smartSplit()  : array<string|int, mixed>

Parses SQL content into individual executable statements.

isQuoteEscaped()  : bool

Checks if a quote at the given position is escaped by backslashes.