NAME
DBIx::Otogiri - Core of Otogiri
SYNOPSIS
use Otogiri;
my $db = Otogiri->new(connect_info => ['dbi:SQLite:...', '', '']);
$db->insert(book => {title => 'mybook1', author => 'me', ...});
my $book_id = $db->last_insert_id;
my $row = $db->single(book => {id => $book_id});
print 'Title: '. $row->{title}. "\n";
my @rows = $db->select(book => {price => {'>=' => 500}});
for my $r (@rows) {
printf "Title: %s \nPrice: %s yen\n", $r->{title}, $r->{price};
}
$db->update(book => [author => 'oreore'], {author => 'me'});
$db->delete(book => {author => 'me'});
### using transaction
do {
my $txn = $db->txn_scope;
$db->insert(book => ...);
$db->insert(store => ...);
$txn->commit;
};
DESCRIPTION
DBIx::Otogiri is core feature class of Otogiri.
ATTRIBUTES
connect_info (required)
connect_info => [$dsn, $dbuser, $dbpass],
You have to specify dsn
, dbuser
, and dbpass
, to connect to database.
strict (optional, default is 1)
In strict mode, all the expressions must be declared by using blessed references that export as_sql and bind methods like SQL::QueryMaker.
Please see METHODS section of SQL::Maker's documentation.
inflate (optional)
use JSON;
inflate => sub {
my ($data, $tablename, $db) = @_;
if (defined $data->{json}) {
$data->{json} = decode_json($data->{json});
}
$data->{table} = $tablename;
$data;
},
You may specify column inflation logic.
Specified code is called internally when called select(), search_by_sql(), and single().
$db
is Otogiri instance, you can use Otogiri's method in inflate logic.
deflate (optional)
use JSON;
deflate => sub {
my ($data, $tablename, $db) = @_;
if (defined $data->{json}) {
$data->{json} = encode_json($data->{json});
}
delete $data->{table};
$data;
},
You may specify column deflation logic.
Specified code is called internally when called insert(), update(), and delete().
$db
is Otogiri instance, you can use Otogiri's method in deflate logic.
METHODS
new
my $db = DBIx::Otogiri->new( connect_info => [$dsn, $dbuser, $dbpass] );
Instantiate and connect to db.
Please see ATTRIBUTE section.
insert / fast_insert
my $is_success = $db->insert($table_name => $columns_in_hashref);
Insert a data simply.
search
select / search
### receive rows of result in array
my @rows = $db->search($table_name => $conditions_in_hashref [,@options]);
### or we can receive result as iterator object
my $iter = $db->search($table_name => $conditions_in_hashref [,@options]);
while (my $row = $iter->next) {
... any logic you want ...
}
printf "rows = %s\n", $iter->fetched_count;
Select from specified table. When you receive result by array, it returns matched rows. Or not, it returns a result as DBIx::Otogiri::Iterator object.
single / fetch
my $row = $db->fetch($table_name => $conditions_in_hashref [,@options]);
Select from specified table. Then, returns first of matched rows.
search_by_sql
my @rows = $db->search_by_sql($sql, \@bind_vals [, $table_name]);
Select by specified SQL. Then, returns matched rows as array. $table_name is optional and used for inflate parameter.
update
$db->update($table_name => [update_col_1 => $new_value_1, ...], $conditions_in_hashref);
Update rows that matched to $conditions_in_hashref.
delete
$db->delete($table_name => $conditions_in_hashref);
Delete rows that matched to $conditions_in_hashref.
do
$db->do($sql, @bind_vals);
Execute specified SQL.
txn_scope
my $txn = $db->txn_scope;
returns DBIx::TransactionManager::ScopeGuard's instance. See DBIx::TransactionManager to more information.
last_insert_id
my $id = $db->last_insert_id([@args]);
returns last_insert_id. (mysql_insertid in MySQL or last_insert_rowid in SQLite)
disconnect
disconnect database.
reconnect
reconnect database.
LICENSE
Copyright (C) ytnobody.
This library is free software; you can redistribute it and/or modify it under the same terms as Perl itself.
AUTHOR
ytnobody <ytnobody@gmail.com>