Merge lp:~brianlmoon/gearmand/sqlite-replace into lp:gearmand/1.0

[Brian Moon]

If the queue is ever out of sync with the daemon memory, inserts into the sqlite queue will prevent jobs from being queued. The memcached queue does not have this problem as it uses a set instead of an add. This will make the sqlite queue work in a similar fashion, replacing any queue item that has the same unique key.

=== modified file 'libgearman-server/queue_libsqlite3.c'
--- libgearman-server/queue_libsqlite3.c	2009-12-30 23:57:45 +0000
+++ libgearman-server/queue_libsqlite3.c	2010-03-16 15:59:13 +0000
@@ -478,7 +478,7 @@
   }
 
   query_size= (size_t)snprintf(query, query_size,
-                               "INSERT INTO %s (priority,unique_key,"
+                               "INSERT OR REPLACE INTO %s (priority,unique_key,"
                                "function_name,data) VALUES (?,?,?,?)",
                                queue->table);
 
@@ -542,6 +542,10 @@
     return GEARMAN_QUEUE_ERROR;
   }
 
+  GEARMAN_SERVER_CRAZY(server,
+                       "sqlite data: priority: %d, unique_key: %s, function_name: %s",
+                       priority, (char*)unique, (char*)function_name);
+
   sqlite3_finalize(sth);
 
   if (_sqlite_commit(server, queue) !=  SQLITE_OK)