effectra / db
The Effectra Database package.
Requires
- bmt/noun-converter: ^1.0
- effectra/data-optimizer: ^1.0
- effectra/event-dispatcher: ^1.0
- effectra/sql-query: ^2.0
- symfony/var-dumper: ^6.0
README
Effectra\Database is a PHP package that provides database connection and query execution functionality. It offers a convenient interface for interacting with different database drivers and executing common database operations.
Installation
You can install the Effectra\Database package via Composer. Simply run the following command:
composer require effectra/db
Usage
Connection
To establish a database connection, you need to create an instance of the Connection
class and call the connect
method. The connect
method retrieves the database configuration from the provided configuration file and returns a PDO object representing the database connection.
use Effectra\Database\Connection; use Effectra\Database\Diver; use Effectra\Config\ConfigDB; // Create a new instance of the Connection class $mysqlConfig = [ 'driver' => 'mysql', 'host' => 'localhost', 'database' => 'your_database_name', 'username' => 'your_mysql_username', 'password' => 'your_mysql_password', 'charset' => 'utf8mb4', 'collation' => 'utf8mb4_unicode_ci', // Add any additional options if needed ]; $connection = new Connection($mysqlConfig);
By default, the Connection
class supports MySQL and SQLite database drivers. You can easily add support for additional database drivers by implementing the DriverInterface
and configuring the Connection
class accordingly.
Query Execution
Once you have established a database connection, you can execute queries using the DB
class. The DB
class provides methods for executing common database operations such as select
, insert
, update
, and delete
.
use Effectra\Database\DB; // Establish the database connection DB::createConnection($con); // Establish the database event dispatcher DB::setEventDispatcher(new EventDispatcher()); // Create a new instance of the DB class $db = new DB(); // Execute a select query $data = $db->withQuery('SELECT * FROM users')->get(); // Execute an insert query $db->table('users')->data(['name' => 'Jane Doe','email'=> 'janeDoe@mail.com'])->insert(); // Execute an update query $db->table('users')->data(['name' => 'Jane Doe'])->update((new Condition())->where(['id' => 2]));
The DB
class provides a fluent interface for building and executing queries. You can chain methods to construct complex queries easily.
Error Handling
If an error occurs during query execution, the DB
class will throw a DatabaseException
. You can catch and handle this exception to gracefully handle database errors.
use Effectra\Database\Exception\DatabaseException; try { $db->table('users')->insert( ['name' => 'John Doe']); // Missing 'email' field } catch (DatabaseException $e) { // Handle the exception echo "Database Error: " . $e->getMessage(); }
Model
-
Namespace: The model is part of the
Effectra\Database
namespace. -
Traits: The model uses the
ModelEventTrait
trait. -
Properties:
$connection
: An instance of theDBInterface
representing the database connection.$schema
: An array containing the schema of the model.$entries
: An array containing the entries of the model.$table
: The name of the table associated with the model.$primaryKey
: The primary key for the model (default is 'id').$keyType
: The data type of the primary key (default is 'int').$incrementing
: Indicates if the model's ID is auto-incrementing (default istrue
).const CREATED_AT
andconst UPDATED_AT
: Constants representing the names of "created at" and "updated at" columns.$options
: Additional options for the model.private static $query
: A static property to store the last executed database query.
-
Constructor:
- The constructor sets the table name if not provided.
-
Methods:
isEntriesCreated()
: Checks if entries have been created for the model.createModelStructure()
: Creates the structure of the model, including schema and entries.getDatabaseConnection()
: Gets a new database connection instance.createSchema()
: Creates the schema for the model by fetching metadata from the database.isSchemaCreated()
: Checks if the schema has been created for the model.createEntriesFromSchema()
: Creates entries for the model based on the schema.- Various methods for setting, getting, and manipulating options.
getSchema($property)
: Gets the schema entry for a specific property.getEntries()
: Gets the entries for the model.hasEntry($property)
: Checks if a specific entry exists in the model.getEntry($property)
: Gets the value of a specific entry in the model.setEntries($entries)
: Sets the entries for the model.setEntry($property, $value)
: Sets a specific entry for the model.removeEntry($property)
: Removes a specific entry from the model.- Various magic methods (
__invoke
,__set
,__get
,__toString
,__isset
,__unset
,__callStatic
,__call
) for dynamic property access and method calls. toArray()
: Converts the model to an array representation.toJson($flags = 0, $depth = 512)
: Converts the model to its JSON representation.save()
: Saves the model to the database.update()
: Updates the model in the database.transaction($callback, ...$args)
: Performs a model operation in a transaction.saveInTransaction($data = [])
: Saves the model in a transaction.updateInTransaction()
: Updates the model in a transaction.- Methods for retrieving models from the database (
get
,all
,limit
,find
,findBy
,search
,where
,between
). - Methods for deleting models from the database (
delete
,deleteById
,deleteByIds
,deleteByIdsInTransaction
). truncate()
: Truncates the model's table.lastInsertId()
: Gets the last inserted ID for the model.validateId($id)
: Validates a model ID.setQuery($query)
: Sets the query instance for the model.getQueryUsed()
: Gets the query instance used by the model.getQueryUsedAsString()
: Gets the query instance used by the model as a string.dd()
: Dumps the model class using Symfony's VarDumper.
Overall, this model provides a flexible and extensible foundation for database interactions in a PHP application. It includes features for CRUD operations, query building, and transaction management. Additionally, it leverages traits for handling model events and uses Symfony's VarDumper for debugging purposes.
Basic Usage
create Model
class User extends Model { }
Retrieve a Record
$user = User::find(1); print_r($user); echo $user->id; // or use method echo $user->getId();
Update a Record
$user->name = 'Foo Bar'; // or use method $user->setName('Foo Bar'); $user->update();
Save a Record
$user = new User(); $user->name = 'Foo Bar'; $user->email = 'FooBar@email.com'; // or use method $user ->setName('Foo Bar'); ->setEmail('FooBar@email.com'); $user->save();
Contributing
Contributions to the Effectra\Database package are welcome. If you find any issues or have suggestions for improvement, please open an issue or submit a pull request on the GitHub repository.
License
The Effectra\Database package is open-source software licensed under the MIT license. See the LICENSE
file for more information.