diff --git a/lib/NGCP/BulkProcessor/Dao/Trunk/billing/lnp_numbers.pm b/lib/NGCP/BulkProcessor/Dao/Trunk/billing/lnp_numbers.pm
index 4cb298a..82b5868 100644
--- a/lib/NGCP/BulkProcessor/Dao/Trunk/billing/lnp_numbers.pm
+++ b/lib/NGCP/BulkProcessor/Dao/Trunk/billing/lnp_numbers.pm
@@ -33,6 +33,8 @@ our @EXPORT_OK = qw(
     delete_row
     
     delete_numbers
+
+    truncate
     
     getinsertstatement
 
@@ -142,6 +144,15 @@ sub delete_row {
 
 }
 
+sub truncate {
+
+    check_table();
+    my $db = &$get_db();
+    $db->truncate_table($tablename);
+    $db->vacuum($tablename);
+
+}
+
 sub delete_numbers {
 
     my ($xa_db,$numbers) = @_;
diff --git a/lib/NGCP/BulkProcessor/Dao/Trunk/billing/lnp_providers.pm b/lib/NGCP/BulkProcessor/Dao/Trunk/billing/lnp_providers.pm
index f438b82..826b144 100644
--- a/lib/NGCP/BulkProcessor/Dao/Trunk/billing/lnp_providers.pm
+++ b/lib/NGCP/BulkProcessor/Dao/Trunk/billing/lnp_providers.pm
@@ -31,6 +31,8 @@ our @EXPORT_OK = qw(
     insert_row
     update_row
     delete_row
+
+    delete_all
     
     findby_prefix
     findby_nameprefixauthoritativeskiprewrite
@@ -158,6 +160,28 @@ sub delete_row {
 
 }
 
+sub delete_all {
+
+    my ($xa_db) = @_;
+
+    check_table();
+    my $db = &$get_db();
+    $xa_db //= $db;
+    my $table = $db->tableidentifier($tablename);
+
+    my $stmt = 'DELETE FROM ' . $table;
+
+    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();