diff --git a/lib/NGCP/BulkProcessor/Dao/Trunk/provisioning/voip_subscriber_profile_sets.pm b/lib/NGCP/BulkProcessor/Dao/Trunk/provisioning/voip_subscriber_profile_sets.pm new file mode 100644 index 0000000..2a11310 --- /dev/null +++ b/lib/NGCP/BulkProcessor/Dao/Trunk/provisioning/voip_subscriber_profile_sets.pm @@ -0,0 +1,152 @@ +package NGCP::BulkProcessor::Dao::Trunk::provisioning::voip_subscriber_profile_sets; +use strict; + +## no critic + +use NGCP::BulkProcessor::Logging qw( + getlogger + rowinserted + +); + +use NGCP::BulkProcessor::ConnectorPool qw( + get_provisioning_db +); + +use NGCP::BulkProcessor::SqlProcessor qw( + checktableinfo + insert_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 + + findby_resellerid_name +); + +my $tablename = 'voip_subscriber_profile_sets'; +my $get_db = \&get_provisioning_db; + +my $expected_fieldnames = [ + 'id', + 'reseller_id', + 'name', + 'description', +]; + +my $indexes = {}; + +my $insert_unique_fields = []; + +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_resellerid_name { + + my ($reseller_id,$name,$load_recursive) = @_; + + check_table(); + my $db = &$get_db(); + my $table = $db->tableidentifier($tablename); + + my $stmt = 'SELECT * FROM ' . $table . ' WHERE ' . + $db->columnidentifier('reseller_id') . ' = ?' . + ' AND ' . $db->columnidentifier('name') . ' = ?'; + my @params = ($reseller_id,$name); + my $rows = $db->db_get_all_arrayref($stmt,@params); + + return buildrecords_fromrows($rows,$load_recursive)->[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 ($reseller_id, + $name, + $description) = @params{qw/ + reseller_id + name + description + /}; + + if ($xa_db->db_do('INSERT INTO ' . $db->tableidentifier($tablename) . ' (' . + $db->columnidentifier('reseller_id') . ', ' . + $db->columnidentifier('name') . ', ' . + $db->columnidentifier('description') . ') VALUES (' . + '?, ' . + '?, ' . + '?)', + $reseller_id, + $name, + $description, + )) { + 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;