TT#81155 subscriber_profile_set DAO

Change-Id: I0bf4ed63d999d86449a5ed3912934f0549a2b851
(cherry picked from commit 8e4de26084)

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;