fix memory leaks

src/macros.h

@@ -156,5 +156,14 @@ const char* sqlite_code_string(int code);
     stmt->db->Process();                                                       \
     delete baton;
 
+#define DELETE_FIELD(field)                                                    \
+    switch ((field)->type) {                                                   \
+        case SQLITE_INTEGER: delete (Data::Integer*)(field); break;            \
+        case SQLITE_FLOAT:   delete (Data::Float*)(field); break;              \
+        case SQLITE_TEXT:    delete (Data::Text*)(field); break;               \
+        case SQLITE_BLOB:    delete (Data::Blob*)(field); break;               \
+        case SQLITE_NULL:    delete (Data::Null*)(field); break;               \
+    }
+
 #endif
 

src/statement.cc

@@ -552,6 +552,7 @@ int Statement::EIO_AfterAll(eio_req *req) {
                 Data::Rows::const_iterator end = baton->rows.end();
                 for (int i = 0; it < end; it++, i++) {
                     result->Set(i, RowToJS(*it));
+                    delete *it;
                 }
 
                 Local<Value> argv[] = { Local<Value>::New(Null()), result };
@@ -758,6 +759,8 @@ Local<Array> Statement::RowToJS(Data::Row* row) {
 
         result->Set(i, value);
         result->Set(String::NewSymbol(field->name.c_str()), value);
+
+        DELETE_FIELD(field);
     }
 
     return result;

src/statement.h

@@ -84,15 +84,16 @@ public:
         Data::Parameters parameters;
 
         Baton(Statement* stmt_, Handle<Function> cb_) : stmt(stmt_) {
-            Data::Parameters::const_iterator it = parameters.begin();
-            Data::Parameters::const_iterator end = parameters.end();
-            for (; it < end; it++) delete *it;
-
             stmt->Ref();
             ev_ref(EV_DEFAULT_UC);
             callback = Persistent<Function>::New(cb_);
         }
         ~Baton() {
+            Data::Parameters::const_iterator it = parameters.begin();
+            Data::Parameters::const_iterator end = parameters.end();
+            for (; it < end; it++) {
+                DELETE_FIELD(*it);
+            }
             stmt->Unref();
             ev_unref(EV_DEFAULT_UC);
             callback.Dispose();