Change-Id: Ie5b16da0361408cabccf7ec41c85bbe1884a9d1achanges/60/35660/3
Rene Krenn
6 years ago
parent
ce57fb5876
commit
7ff2336957
@ -0,0 +1,255 @@
|
|||||||
|
package NGCP::BulkProcessor::Dao::Trunk::provisioning::voip_contract_preferences;
|
||||||
|
use strict;
|
||||||
|
|
||||||
|
## no critic
|
||||||
|
|
||||||
|
use NGCP::BulkProcessor::Logging qw(
|
||||||
|
getlogger
|
||||||
|
rowinserted
|
||||||
|
rowsdeleted
|
||||||
|
);
|
||||||
|
|
||||||
|
use NGCP::BulkProcessor::ConnectorPool qw(
|
||||||
|
get_provisioning_db
|
||||||
|
);
|
||||||
|
|
||||||
|
use NGCP::BulkProcessor::SqlProcessor qw(
|
||||||
|
checktableinfo
|
||||||
|
insert_record
|
||||||
|
update_record
|
||||||
|
delete_record
|
||||||
|
copy_row
|
||||||
|
);
|
||||||
|
use NGCP::BulkProcessor::SqlRecord qw();
|
||||||
|
|
||||||
|
require Exporter;
|
||||||
|
our @ISA = qw(Exporter NGCP::BulkProcessor::SqlRecord);
|
||||||
|
our @EXPORT_OK = qw(
|
||||||
|
gettablename
|
||||||
|
check_table
|
||||||
|
insert_row
|
||||||
|
update_row
|
||||||
|
delete_row
|
||||||
|
|
||||||
|
delete_preferences
|
||||||
|
|
||||||
|
findby_contractid_attributeid
|
||||||
|
countby_contractid_attributeid_value
|
||||||
|
|
||||||
|
$TRUE
|
||||||
|
$FALSE
|
||||||
|
);
|
||||||
|
|
||||||
|
my $tablename = 'voip_contract_preferences';
|
||||||
|
my $get_db = \&get_provisioning_db;
|
||||||
|
|
||||||
|
my $expected_fieldnames = [
|
||||||
|
'id',
|
||||||
|
'contract_id',
|
||||||
|
'attribute_id',
|
||||||
|
'value',
|
||||||
|
'modify_timestamp',
|
||||||
|
'location_id',
|
||||||
|
];
|
||||||
|
|
||||||
|
my $indexes = {};
|
||||||
|
|
||||||
|
my $insert_unique_fields = [];
|
||||||
|
|
||||||
|
our $TRUE = 1;
|
||||||
|
our $FALSE = undef;
|
||||||
|
|
||||||
|
sub new {
|
||||||
|
|
||||||
|
my $class = shift;
|
||||||
|
my $self = NGCP::BulkProcessor::SqlRecord->new($class,$get_db,
|
||||||
|
$tablename,$expected_fieldnames,$indexes);
|
||||||
|
|
||||||
|
copy_row($self,shift,$expected_fieldnames);
|
||||||
|
|
||||||
|
return $self;
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
sub findby_contractid_attributeid {
|
||||||
|
|
||||||
|
my ($xa_db,$contract_id,$attribute_id,$load_recursive) = @_;
|
||||||
|
|
||||||
|
check_table();
|
||||||
|
my $db = &$get_db();
|
||||||
|
$xa_db //= $db;
|
||||||
|
my $table = $db->tableidentifier($tablename);
|
||||||
|
|
||||||
|
my $stmt = 'SELECT * FROM ' . $table . ' WHERE ' .
|
||||||
|
$db->columnidentifier('contract_id') . ' = ?';
|
||||||
|
my @params = ($contract_id);
|
||||||
|
if (defined $attribute_id) {
|
||||||
|
$stmt .= ' AND ' . $db->columnidentifier('contract_id') . ' = ?';
|
||||||
|
push(@params,$attribute_id);
|
||||||
|
}
|
||||||
|
my $rows = $xa_db->db_get_all_arrayref($stmt,@params);
|
||||||
|
|
||||||
|
return buildrecords_fromrows($rows,$load_recursive);
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
sub countby_contractid_attributeid_value {
|
||||||
|
|
||||||
|
my ($contract_id,$attribute_id,$value) = @_;
|
||||||
|
|
||||||
|
check_table();
|
||||||
|
my $db = &$get_db();
|
||||||
|
my $table = $db->tableidentifier($tablename);
|
||||||
|
|
||||||
|
my $stmt = 'SELECT COUNT(*) FROM ' . $table;
|
||||||
|
my @params = ();
|
||||||
|
my @terms = ();
|
||||||
|
if ($contract_id) {
|
||||||
|
push(@terms,$db->columnidentifier('contract_id') . ' = ?');
|
||||||
|
push(@params,$contract_id);
|
||||||
|
}
|
||||||
|
if ($attribute_id) {
|
||||||
|
push(@terms,$db->columnidentifier('attribute_id') . ' = ?');
|
||||||
|
push(@params,$attribute_id);
|
||||||
|
}
|
||||||
|
if ($value) {
|
||||||
|
push(@terms,$db->columnidentifier('value') . ' = ?');
|
||||||
|
push(@params,$value);
|
||||||
|
}
|
||||||
|
if ((scalar @terms) > 0) {
|
||||||
|
$stmt .= ' WHERE ' . join(' AND ',@terms);
|
||||||
|
}
|
||||||
|
|
||||||
|
return $db->db_get_value($stmt,@params);
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
sub update_row {
|
||||||
|
|
||||||
|
my ($xa_db,$data) = @_;
|
||||||
|
|
||||||
|
check_table();
|
||||||
|
return update_record($get_db,$xa_db,__PACKAGE__,$data);
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
sub delete_row {
|
||||||
|
|
||||||
|
my ($xa_db,$data) = @_;
|
||||||
|
|
||||||
|
check_table();
|
||||||
|
return delete_record($get_db,$xa_db,__PACKAGE__,$data);
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
sub delete_preferences {
|
||||||
|
|
||||||
|
my ($xa_db,$contract_id,$attribute_id,$vals) = @_;
|
||||||
|
|
||||||
|
check_table();
|
||||||
|
my $db = &$get_db();
|
||||||
|
$xa_db //= $db;
|
||||||
|
my $table = $db->tableidentifier($tablename);
|
||||||
|
|
||||||
|
my $stmt = 'DELETE FROM ' . $table . ' WHERE ' .
|
||||||
|
$db->columnidentifier('contract_id') . ' = ?';
|
||||||
|
my @params = ($contract_id);
|
||||||
|
if (defined $attribute_id) {
|
||||||
|
$stmt .= ' AND ' . $db->columnidentifier('attribute_id') . ' = ?';
|
||||||
|
push(@params,$attribute_id);
|
||||||
|
}
|
||||||
|
if (defined $vals and 'HASH' eq ref $vals) {
|
||||||
|
foreach my $in (keys %$vals) {
|
||||||
|
my @values = (defined $vals->{$in} and 'ARRAY' eq ref $vals->{$in} ? @{$vals->{$in}} : ($vals->{$in}));
|
||||||
|
$stmt .= ' AND ' . $db->columnidentifier('value') . ' ' . $in . ' (' . substr(',?' x scalar @values,1) . ')';
|
||||||
|
push(@params,@values);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
my $count;
|
||||||
|
if ($count = $xa_db->db_do($stmt,@params)) {
|
||||||
|
rowsdeleted($db,$tablename,$count,$count,getlogger(__PACKAGE__));
|
||||||
|
return 1;
|
||||||
|
} else {
|
||||||
|
rowsdeleted($db,$tablename,0,0,getlogger(__PACKAGE__));
|
||||||
|
return 0;
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
sub insert_row {
|
||||||
|
|
||||||
|
my $db = &$get_db();
|
||||||
|
my $xa_db = shift // $db;
|
||||||
|
if ('HASH' eq ref $_[0]) {
|
||||||
|
my ($data,$insert_ignore) = @_;
|
||||||
|
check_table();
|
||||||
|
if (insert_record($db,$xa_db,__PACKAGE__,$data,$insert_ignore,$insert_unique_fields)) {
|
||||||
|
return $xa_db->db_last_insert_id();
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
my %params = @_;
|
||||||
|
my ($attribute_id,
|
||||||
|
$contract_id,
|
||||||
|
$value) = @params{qw/
|
||||||
|
attribute_id
|
||||||
|
contract_id
|
||||||
|
value
|
||||||
|
/};
|
||||||
|
|
||||||
|
if ($xa_db->db_do('INSERT INTO ' . $db->tableidentifier($tablename) . ' (' .
|
||||||
|
$db->columnidentifier('attribute_id') . ', ' .
|
||||||
|
$db->columnidentifier('contract_id') . ', ' .
|
||||||
|
$db->columnidentifier('value') . ') VALUES (' .
|
||||||
|
'?, ' .
|
||||||
|
'?, ' .
|
||||||
|
'?)',
|
||||||
|
$attribute_id,
|
||||||
|
$contract_id,
|
||||||
|
$value,
|
||||||
|
)) {
|
||||||
|
rowinserted($db,$tablename,getlogger(__PACKAGE__));
|
||||||
|
return $xa_db->db_last_insert_id();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return undef;
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
sub buildrecords_fromrows {
|
||||||
|
|
||||||
|
my ($rows,$load_recursive) = @_;
|
||||||
|
|
||||||
|
my @records = ();
|
||||||
|
my $record;
|
||||||
|
|
||||||
|
if (defined $rows and ref $rows eq 'ARRAY') {
|
||||||
|
foreach my $row (@$rows) {
|
||||||
|
$record = __PACKAGE__->new($row);
|
||||||
|
|
||||||
|
# transformations go here ...
|
||||||
|
|
||||||
|
push @records,$record;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return \@records;
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
sub gettablename {
|
||||||
|
|
||||||
|
return $tablename;
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
sub check_table {
|
||||||
|
|
||||||
|
return checktableinfo($get_db,
|
||||||
|
__PACKAGE__,$tablename,
|
||||||
|
$expected_fieldnames,
|
||||||
|
$indexes);
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
1;
|
||||||
Loading…
Reference in new issue