fix close() bug

define add( $addr ) and delete( $addr ) method

1 files changed, 24 insertions, 0 deletions

diff --git a/fml/lib/IO/Adapter/MySQL.pm b/fml/lib/IO/Adapter/MySQL.pm
index 8614f35b..8eb1859b 100644
--- a/fml/lib/IO/Adapter/MySQL.pm
+++ b/fml/lib/IO/Adapter/MySQL.pm
@@ -117,6 +117,8 @@ sub close
 
     $res->finish     if defined $res;
     $dbh->disconnect if defined $dbh;
+    delete $self->{ _res };
+    delete $self->{ _dbh };
 }
 
 
@@ -256,4 +258,26 @@ sub error
 }
 
 
+=head2 C<add()>
+
+=cut
+
+sub add
+{
+    my ($self, $args) = @_;
+    my $query = $self->_schema_configure('add');
+    $query = sprintf($query, $args);
+    $self->execute({ query => $query });
+}
+
+
+sub delete
+{
+    my ($self, $args) = @_;
+    my $query = $self->_schema_configure('delete');
+    $query = sprintf($query, $args);
+    $self->execute({ query => $query });
+}
+
+
 1;