diff --git a/databases/mysql-proxy/Makefile b/databases/mysql-proxy/Makefile
index f9b513f5361f..1b47e3352f9e 100644
--- a/databases/mysql-proxy/Makefile
+++ b/databases/mysql-proxy/Makefile
@@ -7,7 +7,7 @@
 
 PORTNAME=	mysql-proxy
 PORTVERSION=	0.7.2
-PORTREVISION=	3
+PORTREVISION=	4
 CATEGORIES=	databases
 MASTER_SITES=	${MASTER_SITE_MYSQL}
 MASTER_SITE_SUBDIR=	MySQL-Proxy
diff --git a/databases/mysql-proxy/files/patch-src-network-injection-lua.c b/databases/mysql-proxy/files/patch-src-network-injection-lua.c
new file mode 100644
index 000000000000..f876f7a8585c
--- /dev/null
+++ b/databases/mysql-proxy/files/patch-src-network-injection-lua.c
@@ -0,0 +1,93 @@
+--- src/network-injection-lua.c.orig	2009-06-30 22:47:39.000000000 +0600
++++ src/network-injection-lua.c	2009-11-17 09:39:32.000000000 +0500
+@@ -33,17 +33,18 @@
+ #define TIME_DIFF_US(t2, t1) \
+ ((t2.tv_sec - t1.tv_sec) * 1000000.0 + (t2.tv_usec - t1.tv_usec))
+ 
++typedef enum {
++	PROXY_QUEUE_ADD_PREPEND,
++	PROXY_QUEUE_ADD_APPEND
++} proxy_queue_add_t;
+ 
+ /**
+- * proxy.queries:append(id, packet[, { options }])
++ * handle _append() and _prepend() 
+  *
+- *   id:      opaque numeric id (numeric)
+- *   packet:  mysql packet to append (string)  FIXME: support table for multiple packets
+- *   options: table of options (table)
+- *     backend_ndx:  backend_ndx to send it to (numeric)
+- *     resultset_is_needed: expose the result-set into lua (bool)
++ * _append() and _prepend() have the same behaviour, parameters, ... 
++ * just different in position
+  */
+-static int proxy_queue_append(lua_State *L) {
++static int proxy_queue_add(lua_State *L, proxy_queue_add_t type) {
+ 	GQueue *q = *(GQueue **)luaL_checkself(L);
+ 	int resp_type = luaL_checkinteger(L, 2);
+ 	size_t str_len;
+@@ -68,7 +69,12 @@
+ 		} else if (lua_isboolean(L, -1)) {
+ 			inj->resultset_is_needed = lua_toboolean(L, -1);
+ 		} else {
+-			luaL_argerror(L, 4, ":append(..., { resultset_is_needed = boolean } ), is %s");
++			switch (type) {
++			case PROXY_QUEUE_ADD_APPEND:
++				return luaL_argerror(L, 4, ":append(..., { resultset_is_needed = boolean } ), is %s");
++			case PROXY_QUEUE_ADD_PREPEND:
++				return luaL_argerror(L, 4, ":prepend(..., { resultset_is_needed = boolean } ), is %s");
++			}
+ 		}
+ 
+ 		lua_pop(L, 1);
+@@ -78,25 +84,34 @@
+ 		luaL_typerror(L, 4, "table");
+ 		break;
+ 	}
+-    
+-	network_injection_queue_append(q, inj);
+-    
+-	return 0;
++
++	switch (type) {
++	case PROXY_QUEUE_ADD_APPEND:
++		network_injection_queue_append(q, inj);
++		return 0;
++	case PROXY_QUEUE_ADD_PREPEND:
++		network_injection_queue_prepend(q, inj);
++		return 0;
++	}
++
++	g_assert_not_reached();
++}
++
++/**
++ * proxy.queries:append(id, packet[, { options }])
++ *
++ *   id:      opaque numeric id (numeric)
++ *   packet:  mysql packet to append (string)  FIXME: support table for multiple packets
++ *   options: table of options (table)
++ *     backend_ndx:  backend_ndx to send it to (numeric)
++ *     resultset_is_needed: expose the result-set into lua (bool)
++ */
++static int proxy_queue_append(lua_State *L) {
++	return proxy_queue_add(L, PROXY_QUEUE_ADD_APPEND);
+ }
+ 
+ static int proxy_queue_prepend(lua_State *L) {
+-	/* we expect 2 parameters */
+-	GQueue *q = *(GQueue **)luaL_checkself(L);
+-	int resp_type = luaL_checkinteger(L, 2);
+-	size_t str_len;
+-	const char *str = luaL_checklstring(L, 3, &str_len);
+-    
+-	GString *query = g_string_sized_new(str_len);
+-	g_string_append_len(query, str, str_len);
+-    
+-	network_injection_queue_prepend(q, injection_new(resp_type, query));
+-    
+-	return 0;
++	return proxy_queue_add(L, PROXY_QUEUE_ADD_PREPEND);
+ }
+ 
+ static int proxy_queue_reset(lua_State *L) {