Merge lp:~capttofu/drizzle/memcached-udf-current into lp:~drizzle-trunk/drizzle/development

[CaptTofu]

[CaptTofu (capttofu)]

I propose a merge please - this merge will give all basic memcached UDFs for get/set operations as well as client behavior. This work includes Padraig's and my latest.

[lp:~capttofu/drizzle/memcached-udf-current]

1100. By patg <patg@hanuman> on 2009-07-13

- Added simple test
- Added docs

[Jay Pipes (jaypipes)]

  Review: Resubmit

Hi! As discussed on IRC, we'll need a test suite for this plugin...just
marking this on the review.

[lp:~capttofu/drizzle/memcached-udf-current]

1101. By patg <patg@hanuman> on 2009-07-15

-- Merged from Padraig's repo
-- Added Increment and Decrement, and added tests

1102. By patg <patg@hanuman> on 2009-07-17

* Changed return types for set to true and false, and for get a value or NULL
* Added time value for set

1103. By Patrick <email address hidden> on 2009-07-18

Many functions implemented, pushing

1104. By Patrick <email address hidden> on 2009-07-18

Merge

1105. By Padraig O'Sullivan on 2009-07-22

Updating shell script for memcached UDF test suite.

1106. By Padraig O'Sullivan on 2009-07-22

Minor modifications needed in order for Patrick's new UDF's to compile.

1107. By Padraig O'Sullivan on 2009-07-22

Updating the memcached UDF test suite.

1108. By Padraig O'Sullivan on 2009-07-22

Merge from trunk.

1109. By Patrick Galbraith <email address hidden> on 2009-07-27

More fixes - OS X is even more persnikity

1110. By Patrick Galbraith <email address hidden> on 2009-07-28

- Fixes to replace*
- New test and results

1111. By Patrick Galbraith <email address hidden> on 2009-07-29

* fixed issue of behavior hash result checking
* updated test

[CaptTofu (capttofu)]

> Review: Resubmit
>
> Hi! As discussed on IRC, we'll need a test suite for this plugin...just
> marking this on the review.

Hi!

I added tests, more UDFs, and tests pass!

So, may this branch please be merged?

Regards,

Patrick

[Monty Taylor (mordred)]

-----BEGIN PGP SIGNED MESSAGE-----
Hash: SHA1

CaptTofu wrote:
>> Review: Resubmit
>>
>> Hi! As discussed on IRC, we'll need a test suite for this plugin...just
>> marking this on the review.
>
> Hi!
>
> I added tests, more UDFs, and tests pass!
>
> So, may this branch please be merged?

Yes... except I'm going to make you wait just a little while longer...
as soon as my most recent changes to plugin stuff hit trunk (should be
today), I want to get you to merge up, and then you can add a new
magical line to your plugin.ini ... testsuite=whatever ... which will
cause the standard make test to run your plugin's test suite as long as
we built the plugin.

woot.

Then I'll merge you. Promise.

Monty
-----BEGIN PGP SIGNATURE-----
Version: GnuPG v1.4.9 (GNU/Linux)
Comment: Using GnuPG with Mozilla - http://enigmail.mozdev.org

iEYEARECAAYFAkpwmpQACgkQ2Jv7/VK1RgHJBQCeJrvsW25ONOkVTKiKJ7MnFp1+
czwAn3oBxlpo6TYMGhH/FrT87xWiV9G2
=ugE6
-----END PGP SIGNATURE-----

[Stewart Smith (stewart)]

review: Approve

[Monty Taylor (mordred)]

Hullo.

"%llu" should not be used. That needs be changed to "%"PRIu64 to match your uint64_t variable.

The test suite did not work for me. I started a memcached, no dice. So I started using port 19191 like the script in tests/suite/memcached_udf indicated. Still no luck. (BTW, /etc/sysconfig is redhat specific)

The tests in gearman start and stop memcached as needed ... but I think at some point we should figure that out systemically.

review: Needs Fixing

[Padraig O'Sullivan (posulliv)]

So for the test suite, I checked it out and the issue is that the result file seems to not have been updated after some UDF's return types were changed? When I run the test suite, I see there are a few diff's (this is just a sampling, there are more diff's):

 memc_delete('mysql:doc1')
-0
+1
 select memc_get('mysql:doc1');
 memc_get('mysql:doc1')
 NULL
 select memc_set('spot:test', ' Spot ');
 memc_set('spot:test', ' Spot ')
-0
+1
 select memc_get('spot:test');
 memc_get('spot:test')
-NULL
+ Spot
 select memc_prepend('spot:test', 'See');
 memc_prepend('spot:test', 'See')
-0
+1
 select memc_get('spot:test');
 memc_get('spot:test')
-NULL
+See Spot

It looks like the result file was recorded on a test run when all these UDF's failed! To record the result file, do the following:

$ ./dtr --record --suite=memcached_udf memc

Since I wrote the test suite, I should comment on some issues I see with the test suite:

 * it requires memcached to be in your path before running
 * it always starts memcached on the same port so if memcached is already running on this port, bad things will happen
 * the test cases are hard-coded to use a memcached instance on this port

I guess the major question I have here is how to have a test case with the ability to take an input parameter that can affect the result output (in this case, the port number to start memcached on)? I'm assuming its not possible right now unless we pass the parameter as an environment variable but I don't know how to access an environment variable from a test case?

Also, Monty's comment on not using %llu also needs to be implemented. Not sure how this branch compiled cleanly with that in there? I had to modify that to compile the branch and run the test suite.

-Padraig

review: Needs Fixing

[lp:~capttofu/drizzle/memcached-udf-current]

1112. By Patrick Galbraith <email address hidden> on 2009-08-09

* Fixed distribution type check to use iterator to check if a distribution is truly defined
* Fixed hash type check to use iterator check
* Re-recorded the test results

[CaptTofu (capttofu)]

Hi Padraig,

My bad - I was so focused on checking the results for the behavior issue
I didn't double check this! It appears the memcached server didn't start
in this instance when I recorded it.

I've pushed a new version into
lp:~capttofu/drizzle/memcached-udf-current. I also fixed the same issue
that I fixed for behavior types for hash and distribution types. I still
have some issues with some of the behavior settings though that I need
to ask Trond or Brian about (or someone else) as to why when I set some
of the behavior settings, they end up being set to zero. It might be
that the setting I'm trying to assign it is out of bounds and the value
then defaults to zero.

Thanks much!

Other things I need to look at (by tomorrow or tuesday will have done so
this branch can be marged) are the changes that Monty Taylor told me
about that are currently in command_log, pertaining to the loading of
the plugin.

--Patrick

Padraig O'Sullivan wrote:
> Review: Needs Fixing
> So for the test suite, I checked it out and the issue is that the result file seems to not have been updated after some UDF's return types were changed? When I run the test suite, I see there are a few diff's (this is just a sampling, there are more diff's):
>
> memc_delete('mysql:doc1')
> -0
> +1
> select memc_get('mysql:doc1');
> memc_get('mysql:doc1')
> NULL
> select memc_set('spot:test', ' Spot ');
> memc_set('spot:test', ' Spot ')
> -0
> +1
> select memc_get('spot:test');
> memc_get('spot:test')
> -NULL
> + Spot
> select memc_prepend('spot:test', 'See');
> memc_prepend('spot:test', 'See')
> -0
> +1
> select memc_get('spot:test');
> memc_get('spot:test')
> -NULL
> +See Spot
>
> It looks like the result file was recorded on a test run when all these UDF's failed! To record the result file, do the following:
>
> $ ./dtr --record --suite=memcached_udf memc
>
> Since I wrote the test suite, I should comment on some issues I see with the test suite:
>
> * it requires memcached to be in your path before running
> * it always starts memcached on the same port so if memcached is already running on this port, bad things will happen
> * the test cases are hard-coded to use a memcached instance on this port
>
> I guess the major question I have here is how to have a test case with the ability to take an input parameter that can affect the result output (in this case, the port number to start memcached on)? I'm assuming its not possible right now unless we pass the parameter as an environment variable but I don't know how to access an environment variable from a test case?
>
> Also, Monty's comment on not using %llu also needs to be implemented. Not sure how this branch compiled cleanly with that in there? I had to modify that to compile the branch and run the test suite.
>
> -Padraig
>

[lp:~capttofu/drizzle/memcached-udf-current]

1113. By Patrick Galbraith <email address hidden> on 2009-08-12

Merged in Padraig's changes - thanks Padraig!

* He removed the Redhat-specific code in the memcached startup script
* Removed tests that need looking into further and could be system-specific, causing failures
* Added the test suite to plugin.ini

1114. By Patrick Galbraith <email address hidden> on 2009-09-21

Memcached UDFs working with plugin slot re-org. Also merged with latest.

Ok, Monty, so, you won't change anything for a little while? :) Joking. Sort of.

1115. By Patrick Galbraith <email address hidden> on 2009-09-23

* Changed true/false functions to return actual int values vs. strings
* Code cleanup

1116. By Patrick Galbraith <email address hidden> on 2009-09-23

modified all set-type memcached UDFs to return 0 for failure.

1117. By Patrick Galbraith <email address hidden> on 2009-09-23

A couple more review fixes

1118. By Patrick Galbraith <email address hidden> on 2009-10-01

Changed License to BSD

1119. By Patrick Galbraith <email address hidden> on 2009-10-05

Changes per review by Padraig O'Sullivan

1120. By Patrick Galbraith <email address hidden> on 2009-10-05

* Merge with latest trunk
* Changes per Posulliv

Unmerged revisions

1120. By Patrick Galbraith <email address hidden> on 2009-10-05

* Merge with latest trunk
* Changes per Posulliv

1119. By Patrick Galbraith <email address hidden> on 2009-10-05

Changes per review by Padraig O'Sullivan

1118. By Patrick Galbraith <email address hidden> on 2009-10-01

Changed License to BSD

1117. By Patrick Galbraith <email address hidden> on 2009-09-23

A couple more review fixes

1116. By Patrick Galbraith <email address hidden> on 2009-09-23

modified all set-type memcached UDFs to return 0 for failure.

1115. By Patrick Galbraith <email address hidden> on 2009-09-23

* Changed true/false functions to return actual int values vs. strings
* Code cleanup

1114. By Patrick Galbraith <email address hidden> on 2009-09-21

Memcached UDFs working with plugin slot re-org. Also merged with latest.

Ok, Monty, so, you won't change anything for a little while? :) Joking. Sort of.

1113. By Patrick Galbraith <email address hidden> on 2009-08-12

Merged in Padraig's changes - thanks Padraig!

* He removed the Redhat-specific code in the memcached startup script
* Removed tests that need looking into further and could be system-specific, causing failures
* Added the test suite to plugin.ini

1112. By Patrick Galbraith <email address hidden> on 2009-08-09

* Fixed distribution type check to use iterator to check if a distribution is truly defined
* Fixed hash type check to use iterator check
* Re-recorded the test results

1111. By Patrick Galbraith <email address hidden> on 2009-07-29

* fixed issue of behavior hash result checking
* updated test

=== added directory 'plugin/memcached_udf'
=== added file 'plugin/memcached_udf/memc_append.cc'
--- plugin/memcached_udf/memc_append.cc	1970-01-01 00:00:00 +0000
+++ plugin/memcached_udf/memc_append.cc	2009-07-12 04:13:35 +0000
@@ -0,0 +1,57 @@
+/* - mode: c; c-basic-offset: 2; indent-tabs-mode: nil; -*-
+ *  vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
+ *
+ *  Copyright (C) 2009 Sun Microsystems
+ *
+ *  This program is free software; you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation; either version 2 of the License, or
+ *  (at your option) any later version.
+ *
+ *  This program is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License
+ *  along with this program; if not, write to the Free Software
+ *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
+ */
+
+#include <drizzled/server_includes.h>
+#include <drizzled/sql_udf.h>
+#include <drizzled/function/str/strfunc.h>
+
+#include "memcached_udf.h"
+#include "memc_append.h"
+
+#include <libmemcached/memcached.h>
+
+#include <string>
+
+using namespace std;
+
+String *MemcachedAppend::val_str(String *str)
+{
+  memcached_return rc;
+  String *key;
+  String *value;
+
+  if (arg_count != 2 ||
+      ! (key= args[0]->val_str(str)) ||
+      ! (value= args[1]->val_str(str)) ||
+      ! memc)
+  {
+    return &failure_buff;
+  }
+
+  rc= memcached_append(memc, key->c_ptr(), key->length(),
+                       value->c_ptr(), value->length(), 0, 0);
+  if (rc != MEMCACHED_SUCCESS)
+  {
+    return &failure_buff;
+  }
+
+  return &success_buff;
+}
+

=== added file 'plugin/memcached_udf/memc_append.h'
--- plugin/memcached_udf/memc_append.h	1970-01-01 00:00:00 +0000
+++ plugin/memcached_udf/memc_append.h	2009-07-12 04:13:35 +0000
@@ -0,0 +1,56 @@
+/* - mode: c; c-basic-offset: 2; indent-tabs-mode: nil; -*-
+ *  vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
+ *
+ *  Copyright (C) 2009 Sun Microsystems
+ *
+ *  This program is free software; you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation; either version 2 of the License, or
+ *  (at your option) any later version.
+ *
+ *  This program is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License
+ *  along with this program; if not, write to the Free Software
+ *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
+ */
+
+#ifndef MEMC_APPEND_H
+#define MEMC_APPEND_H
+
+#include <drizzled/server_includes.h>
+#include <drizzled/sql_udf.h>
+#include <drizzled/function/str/strfunc.h>
+
+/* implements memc_append */
+class MemcachedAppend : public Item_str_func
+{
+public:
+  MemcachedAppend()
+    : 
+      Item_str_func(),
+      failure_buff("FAILURE", &my_charset_bin),
+      success_buff("SUCCESS", &my_charset_bin)
+  {}
+
+  const char *func_name() const
+  {
+    return "memc_append";
+  }
+
+  String *val_str(String *);
+
+  void fix_length_and_dec()
+  {
+    max_length= 32;
+  }
+
+private:
+  String failure_buff;
+  String success_buff;
+};
+
+#endif /* MEMC_APPEND_H */

=== added file 'plugin/memcached_udf/memc_behavior_get.cc'
--- plugin/memcached_udf/memc_behavior_get.cc	1970-01-01 00:00:00 +0000
+++ plugin/memcached_udf/memc_behavior_get.cc	2009-07-13 14:55:27 +0000
@@ -0,0 +1,140 @@
+/* - mode: c; c-basic-offset: 2; indent-tabs-mode: nil; -*-
+ *  vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
+ *
+ *  Copyright (C) 2009 Sun Microsystems
+ *
+ *  This program is free software; you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation; either version 2 of the License, or
+ *  (at your option) any later version.
+ *
+ *  This program is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License
+ *  along with this program; if not, write to the Free Software
+ *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
+ */
+
+#include <drizzled/server_includes.h>
+#include <drizzled/sql_udf.h>
+#include <drizzled/item/func.h>
+#include <drizzled/function/str/strfunc.h>
+
+#include "memcached_udf.h"
+#include "memc_behavior_get.h"
+
+#include <libmemcached/memcached.h>
+
+#include <string>
+#include <algorithm>
+
+using namespace std;
+
+void MemcachedBehaviorGet::setFailureString(const char *error)
+{
+  size_t size= strlen(error);
+  failure_buff.realloc(size);
+  failure_buff.length(size);
+  memcpy(failure_buff.ptr(), error, size);
+}
+
+String *MemcachedBehaviorGet::val_str(String *str)
+{
+  memcached_behavior mbehavior;
+  uint64_t isetting;
+  String *tmp_behavior;
+
+  if (arg_count != 1 ||
+      ! (tmp_behavior= args[0]->val_str(str)) ||
+      ! memc)
+  {
+    setFailureString("USAGE: memc_behavior_get('<behavior type>')");
+    return &failure_buff;
+  }
+
+  string behavior(tmp_behavior->c_ptr());
+
+  /*
+   * We don't want the user to have to type in all input in upper
+   * case so we transform the input strings to upper case here.
+   */
+  std::transform(behavior.begin(), behavior.end(),
+                 behavior.begin(), ::toupper);
+
+
+  mbehavior= behavior_map[behavior];
+
+  if (! mbehavior)
+  {
+    setFailureString("UNKNOWN BEHAVIOR TYPE!");
+    return &failure_buff;
+  }
+
+  isetting= memcached_behavior_get(memc, mbehavior);
+
+  switch (mbehavior)
+  {
+  case MEMCACHED_BEHAVIOR_SUPPORT_CAS:
+  case MEMCACHED_BEHAVIOR_NO_BLOCK:
+  case MEMCACHED_BEHAVIOR_BUFFER_REQUESTS:
+  case MEMCACHED_BEHAVIOR_USER_DATA:
+  case MEMCACHED_BEHAVIOR_SORT_HOSTS:
+  case MEMCACHED_BEHAVIOR_VERIFY_KEY:
+  case MEMCACHED_BEHAVIOR_TCP_NODELAY:
+  case MEMCACHED_BEHAVIOR_KETAMA:
+  case MEMCACHED_BEHAVIOR_CACHE_LOOKUPS:
+    if (isetting == 1)
+      return_buff.append("1");
+    else if (isetting == 0)
+      return_buff.append("0");
+    else
+    {
+      setFailureString("INVALID VALUE FOR BEHAVIOR - MUST be 1 OR 0!");
+      return &failure_buff;
+    }
+    break;
+  case MEMCACHED_BEHAVIOR_DISTRIBUTION:
+    {
+      string setting(dist_settings_reverse_map[isetting]);
+      return_buff.append(setting.c_str());
+    }
+    break;
+  case MEMCACHED_BEHAVIOR_HASH:
+    {
+      string setting(hash_settings_reverse_map[isetting]);
+      return_buff.append(setting.c_str());
+    }
+    break;
+  case MEMCACHED_BEHAVIOR_KETAMA_HASH:
+    {
+      string setting(ketama_hash_settings_reverse_map[isetting]);
+      return_buff.append(setting.c_str());
+    }
+    break;
+  case MEMCACHED_BEHAVIOR_SOCKET_SEND_SIZE:
+  case MEMCACHED_BEHAVIOR_SOCKET_RECV_SIZE:
+  case MEMCACHED_BEHAVIOR_POLL_TIMEOUT:
+  case MEMCACHED_BEHAVIOR_CONNECT_TIMEOUT:
+  case MEMCACHED_BEHAVIOR_RETRY_TIMEOUT:
+  case MEMCACHED_BEHAVIOR_IO_MSG_WATERMARK:
+  case MEMCACHED_BEHAVIOR_IO_BYTES_WATERMARK:
+    {
+      size_t setting_len= 0;
+      char tmp_buff[10];
+
+      sprintf(tmp_buff, "%lu", isetting);
+      setting_len= strlen(tmp_buff);
+      return_buff.realloc(setting_len);
+      return_buff.length(setting_len);
+      memcpy(return_buff.ptr(),tmp_buff, setting_len);
+    }
+    break;
+  default:
+    break;
+  }
+
+  return &return_buff;
+}

=== added file 'plugin/memcached_udf/memc_behavior_get.h'
--- plugin/memcached_udf/memc_behavior_get.h	1970-01-01 00:00:00 +0000
+++ plugin/memcached_udf/memc_behavior_get.h	2009-07-13 14:02:39 +0000
@@ -0,0 +1,215 @@
+/* - mode: c; c-basic-offset: 2; indent-tabs-mode: nil; -*-
+ *  vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
+ *
+ *  Copyright (C) 2009 Sun Microsystems
+ *
+ *  This program is free software; you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation; either version 2 of the License, or
+ *  (at your option) any later version.
+ *
+ *  This program is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License
+ *  along with this program; if not, write to the Free Software
+ *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
+ */
+
+#ifndef MEMC_BEHAVIOR_GET_H
+#define MEMC_BEHAVIOR_GET_H
+
+#include <drizzled/server_includes.h>
+#include <drizzled/sql_udf.h>
+#include <drizzled/item/func.h>
+
+#include <libmemcached/memcached.h>
+
+#include <map>
+#include <string>
+
+/* implements memc_behavior_get */
+class MemcachedBehaviorGet : public Item_str_func
+{
+public:
+  MemcachedBehaviorGet()
+    : 
+      Item_str_func(),
+      failure_buff("FAILURE", &my_charset_bin),
+      return_buff("", &my_charset_bin),
+      behavior_map(),
+      behavior_reverse_map(),
+      dist_settings_reverse_map(),
+      hash_settings_reverse_map(),
+      ketama_hash_settings_reverse_map()
+  {
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_SUPPORT_CAS", MEMCACHED_BEHAVIOR_SUPPORT_CAS));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_NO_BLOCK", MEMCACHED_BEHAVIOR_NO_BLOCK));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_TCP_NODELAY", MEMCACHED_BEHAVIOR_TCP_NODELAY));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_HASH", MEMCACHED_BEHAVIOR_HASH));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_CACHE_LOOKUPS", MEMCACHED_BEHAVIOR_CACHE_LOOKUPS));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_SOCKET_SEND_SIZE", MEMCACHED_BEHAVIOR_SOCKET_SEND_SIZE));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_SOCKET_RECV_SIZE", MEMCACHED_BEHAVIOR_SOCKET_RECV_SIZE));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_BUFFER_REQUESTS", MEMCACHED_BEHAVIOR_BUFFER_REQUESTS));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_KETAMA", MEMCACHED_BEHAVIOR_KETAMA));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_POLL_TIMEOUT", MEMCACHED_BEHAVIOR_POLL_TIMEOUT));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_RETRY_TIMEOUT", MEMCACHED_BEHAVIOR_RETRY_TIMEOUT));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_DISTRIBUTION", MEMCACHED_BEHAVIOR_DISTRIBUTION));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_USER_DATA", MEMCACHED_BEHAVIOR_USER_DATA));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_SORT_HOSTS", MEMCACHED_BEHAVIOR_SORT_HOSTS));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_VERIFY_KEY", MEMCACHED_BEHAVIOR_VERIFY_KEY));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_CONNECT_TIMEOUT", MEMCACHED_BEHAVIOR_CONNECT_TIMEOUT));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_KETAMA_WEIGHTED", MEMCACHED_BEHAVIOR_KETAMA_WEIGHTED));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_KETAMA_HASH", MEMCACHED_BEHAVIOR_KETAMA_HASH));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_BINARY_PROTOCOL", MEMCACHED_BEHAVIOR_BINARY_PROTOCOL));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_SND_TIMEOUT", MEMCACHED_BEHAVIOR_SND_TIMEOUT));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_RCV_TIMEOUT", MEMCACHED_BEHAVIOR_RCV_TIMEOUT));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_SERVER_FAILURE_LIMIT", MEMCACHED_BEHAVIOR_SERVER_FAILURE_LIMIT));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_IO_MSG_WATERMARK", MEMCACHED_BEHAVIOR_IO_MSG_WATERMARK));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_IO_BYTES_WATERMARK", MEMCACHED_BEHAVIOR_IO_BYTES_WATERMARK));
+
+    behavior_reverse_map.insert(std::pair<memcached_behavior, const std::string>
+      (MEMCACHED_BEHAVIOR_SUPPORT_CAS, "MEMCACHED_BEHAVIOR_SUPPORT_CAS"));
+    behavior_reverse_map.insert(std::pair<memcached_behavior,const std::string>
+      (MEMCACHED_BEHAVIOR_NO_BLOCK, "MEMCACHED_BEHAVIOR_NO_BLOCK"));
+    behavior_reverse_map.insert(std::pair<memcached_behavior,const std::string>
+      (MEMCACHED_BEHAVIOR_TCP_NODELAY, "MEMCACHED_BEHAVIOR_TCP_NODELAY"));
+    behavior_reverse_map.insert(std::pair<memcached_behavior,const std::string>
+      (MEMCACHED_BEHAVIOR_HASH, "MEMCACHED_BEHAVIOR_HASH"));
+    behavior_reverse_map.insert(std::pair<memcached_behavior,const std::string>
+      (MEMCACHED_BEHAVIOR_CACHE_LOOKUPS, "MEMCACHED_BEHAVIOR_CACHE_LOOKUPS"));
+    behavior_reverse_map.insert(std::pair<memcached_behavior,const std::string>
+      (MEMCACHED_BEHAVIOR_SOCKET_SEND_SIZE, "MEMCACHED_BEHAVIOR_SOCKET_SEND_SIZE"));
+    behavior_reverse_map.insert(std::pair<memcached_behavior,const std::string>
+      (MEMCACHED_BEHAVIOR_SOCKET_RECV_SIZE, "MEMCACHED_BEHAVIOR_SOCKET_RECV_SIZE"));
+    behavior_reverse_map.insert(std::pair<memcached_behavior,const std::string>
+      (MEMCACHED_BEHAVIOR_BUFFER_REQUESTS, "MEMCACHED_BEHAVIOR_BUFFER_REQUESTS"));
+    behavior_reverse_map.insert(std::pair<memcached_behavior,const std::string>
+      (MEMCACHED_BEHAVIOR_KETAMA, "MEMCACHED_BEHAVIOR_KETAMA"));
+    behavior_reverse_map.insert(std::pair<memcached_behavior,const std::string>
+      (MEMCACHED_BEHAVIOR_POLL_TIMEOUT, "MEMCACHED_BEHAVIOR_POLL_TIMEOUT"));
+    behavior_reverse_map.insert(std::pair<memcached_behavior,const std::string>
+      (MEMCACHED_BEHAVIOR_RETRY_TIMEOUT, "MEMCACHED_BEHAVIOR_RETRY_TIMEOUT"));
+    behavior_reverse_map.insert(std::pair<memcached_behavior,const std::string>
+      (MEMCACHED_BEHAVIOR_DISTRIBUTION, "MEMCACHED_BEHAVIOR_DISTRIBUTION"));
+    behavior_reverse_map.insert(std::pair<memcached_behavior,const std::string>
+      (MEMCACHED_BEHAVIOR_USER_DATA, "MEMCACHED_BEHAVIOR_USER_DATA"));
+    behavior_reverse_map.insert(std::pair<memcached_behavior,const std::string>
+      (MEMCACHED_BEHAVIOR_SORT_HOSTS, "MEMCACHED_BEHAVIOR_SORT_HOSTS"));
+    behavior_reverse_map.insert(std::pair<memcached_behavior,const std::string>
+      (MEMCACHED_BEHAVIOR_VERIFY_KEY, "MEMCACHED_BEHAVIOR_VERIFY_KEY"));
+    behavior_reverse_map.insert(std::pair<memcached_behavior,const std::string>
+      (MEMCACHED_BEHAVIOR_CONNECT_TIMEOUT, "MEMCACHED_BEHAVIOR_CONNECT_TIMEOUT"));
+    behavior_reverse_map.insert(std::pair<memcached_behavior,const std::string>
+      (MEMCACHED_BEHAVIOR_KETAMA_WEIGHTED, "MEMCACHED_BEHAVIOR_KETAMA_WEIGHTED"));
+    behavior_reverse_map.insert(std::pair<memcached_behavior,const std::string>
+      (MEMCACHED_BEHAVIOR_KETAMA_HASH, "MEMCACHED_BEHAVIOR_KETAMA_HASH"));
+    behavior_reverse_map.insert(std::pair<memcached_behavior,const std::string>
+      (MEMCACHED_BEHAVIOR_BINARY_PROTOCOL, "MEMCACHED_BEHAVIOR_BINARY_PROTOCOL"));
+    behavior_reverse_map.insert(std::pair<memcached_behavior,const std::string>
+      (MEMCACHED_BEHAVIOR_SND_TIMEOUT, "MEMCACHED_BEHAVIOR_SND_TIMEOUT"));
+    behavior_reverse_map.insert(std::pair<memcached_behavior,const std::string>
+      (MEMCACHED_BEHAVIOR_RCV_TIMEOUT, "MEMCACHED_BEHAVIOR_RCV_TIMEOUT"));
+    behavior_reverse_map.insert(std::pair<memcached_behavior,const std::string>
+      (MEMCACHED_BEHAVIOR_SERVER_FAILURE_LIMIT, "MEMCACHED_BEHAVIOR_SERVER_FAILURE_LIMIT"));
+    behavior_reverse_map.insert(std::pair<memcached_behavior,const std::string>
+      (MEMCACHED_BEHAVIOR_IO_MSG_WATERMARK, "MEMCACHED_BEHAVIOR_IO_MSG_WATERMARK"));
+    behavior_reverse_map.insert(std::pair<memcached_behavior,const std::string>
+      (MEMCACHED_BEHAVIOR_IO_BYTES_WATERMARK, "MEMCACHED_BEHAVIOR_IO_BYTES_WATERMARK"));
+
+    dist_settings_reverse_map.insert(std::pair<uint64_t, const std::string>
+      (MEMCACHED_DISTRIBUTION_MODULA, "MEMCACHED_DISTRIBUTION_MODULA"));
+    dist_settings_reverse_map.insert(std::pair<uint64_t, const std::string>
+      (MEMCACHED_DISTRIBUTION_CONSISTENT, "MEMCACHED_DISTRIBUTION_CONSISTENT"));
+    dist_settings_reverse_map.insert(std::pair<uint64_t, const std::string>
+      (MEMCACHED_DISTRIBUTION_CONSISTENT_KETAMA, "MEMCACHED_DISTRIBUTION_CONSISTENT_KETAMA"));
+
+    hash_settings_reverse_map.insert(std::pair<uint64_t, const std::string>
+      (MEMCACHED_HASH_DEFAULT, "MEMCACHED_HASH_DEFAULT"));
+    hash_settings_reverse_map.insert(std::pair<uint64_t, const std::string>
+      (MEMCACHED_HASH_MD5, "MEMCACHED_HASH_MD5"));
+    hash_settings_reverse_map.insert(std::pair<uint64_t, const std::string>
+      (MEMCACHED_HASH_CRC, "MEMCACHED_HASH_CRC"));
+    hash_settings_reverse_map.insert(std::pair<uint64_t, const std::string>
+      (MEMCACHED_HASH_FNV1_64, "MEMCACHED_HASH_FNV1_64"));
+    hash_settings_reverse_map.insert(std::pair<uint64_t, const std::string>
+      (MEMCACHED_HASH_FNV1A_64, "MEMCACHED_HASH_FNV1A_64"));
+    hash_settings_reverse_map.insert(std::pair<uint64_t, const std::string>
+      (MEMCACHED_HASH_FNV1_32, "MEMCACHED_HASH_FNV1_32"));
+    hash_settings_reverse_map.insert(std::pair<uint64_t, const std::string>
+      (MEMCACHED_HASH_FNV1A_32, "MEMCACHED_HASH_FNV1A_32"));
+    hash_settings_reverse_map.insert(std::pair<uint64_t, const std::string>
+      (MEMCACHED_HASH_JENKINS, "MEMCACHED_HASH_JENKINS"));
+    hash_settings_reverse_map.insert(std::pair<uint64_t, const std::string>
+      (MEMCACHED_HASH_HSIEH, "MEMCACHED_HASH_HSIEH"));
+    hash_settings_reverse_map.insert(std::pair<uint64_t, const std::string>
+      (MEMCACHED_HASH_MURMUR, "MEMCACHED_HASH_MURMUR"));
+
+    ketama_hash_settings_reverse_map.insert(std::pair<uint64_t, const std::string>
+      (MEMCACHED_HASH_DEFAULT, "MEMCACHED_HASH_DEFAULT"));
+    ketama_hash_settings_reverse_map.insert(std::pair<uint64_t, const std::string>
+      (MEMCACHED_HASH_MD5, "MEMCACHED_HASH_MD5"));
+    ketama_hash_settings_reverse_map.insert(std::pair<uint64_t, const std::string>
+      (MEMCACHED_HASH_CRC, "MEMCACHED_HASH_CRC"));
+    ketama_hash_settings_reverse_map.insert(std::pair<uint64_t, const std::string>
+      (MEMCACHED_HASH_FNV1_64, "MEMCACHED_HASH_FNV1_64"));
+    ketama_hash_settings_reverse_map.insert(std::pair<uint64_t, const std::string>
+      (MEMCACHED_HASH_FNV1A_64, "MEMCACHED_HASH_FNV1A_64"));
+    ketama_hash_settings_reverse_map.insert(std::pair<uint64_t, const std::string>
+      (MEMCACHED_HASH_FNV1_32, "MEMCACHED_HASH_FNV1_32"));
+    ketama_hash_settings_reverse_map.insert(std::pair<uint64_t, const std::string>
+      (MEMCACHED_HASH_FNV1A_32, "MEMCACHED_HASH_FNV1A_32"));
+  }
+
+  const char *func_name() const
+  {
+    return "memc_behavior_set";
+  }
+
+  String *val_str(String *);
+
+  void fix_length_and_dec()
+  {
+    max_length= 32;
+  }
+
+private:
+  void setFailureString(const char *error);
+
+  String failure_buff;
+  String return_buff;
+
+  std::map<const std::string, memcached_behavior> behavior_map;
+  std::map<memcached_behavior, const std::string> behavior_reverse_map;
+  std::map<uint64_t, const std::string> dist_settings_reverse_map;
+  std::map<uint64_t, const std::string> hash_settings_reverse_map;
+  std::map<uint64_t, const std::string> ketama_hash_settings_reverse_map;
+};
+
+#endif /* MEMC_BEHAVIOR_GET_H */

=== added file 'plugin/memcached_udf/memc_behavior_set.cc'
--- plugin/memcached_udf/memc_behavior_set.cc	1970-01-01 00:00:00 +0000
+++ plugin/memcached_udf/memc_behavior_set.cc	2009-07-13 14:02:39 +0000
@@ -0,0 +1,154 @@
+/* - mode: c; c-basic-offset: 2; indent-tabs-mode: nil; -*-
+ *  vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
+ *
+ *  Copyright (C) 2009 Sun Microsystems
+ *
+ *  This program is free software; you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation; either version 2 of the License, or
+ *  (at your option) any later version.
+ *
+ *  This program is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License
+ *  along with this program; if not, write to the Free Software
+ *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
+ */
+
+#include <drizzled/server_includes.h>
+#include <drizzled/sql_udf.h>
+#include <drizzled/item/func.h>
+#include <drizzled/function/str/strfunc.h>
+
+#include "memcached_udf.h"
+#include "memc_behavior_set.h"
+
+#include <libmemcached/memcached.h>
+
+#include <string>
+#include <algorithm>
+
+using namespace std;
+
+void MemcachedBehaviorSet::setFailureString(const char *error)
+{
+  size_t size= strlen(error);
+  failure_buff.realloc(size);
+  failure_buff.length(size);
+  memcpy(failure_buff.ptr(), error, size);
+}
+
+String *MemcachedBehaviorSet::val_str(String *str)
+{
+  memcached_return rc;
+  memcached_behavior mbehavior;
+  uint64_t isetting= 0;
+  String *tmp_behavior;
+  String *tmp_setting;
+
+  if (arg_count != 2 ||
+      ! (tmp_behavior= args[0]->val_str(str)) ||
+      ! (tmp_setting= args[1]->val_str(str)) ||
+      ! memc)
+  {
+    setFailureString("USAGE: memc_behavior_set('<behavior type>','<value>')");
+    return &failure_buff;
+  }
+
+  string behavior(tmp_behavior->c_ptr());
+  string setting(tmp_setting->c_ptr());
+
+  /*
+   * We don't want the user to have to type in all input in upper
+   * case so we transform the input strings to upper case here.
+   */
+  std::transform(behavior.begin(), behavior.end(),
+                 behavior.begin(), ::toupper);
+  std::transform(setting.begin(), setting.end(),
+                 setting.begin(), ::toupper);
+
+  mbehavior= behavior_map[behavior];
+  if (! mbehavior)
+  {
+    setFailureString("UNKNOWN BEHAVIOR TYPE!");
+    return &failure_buff;
+  }
+
+  switch (mbehavior)
+  {
+  case MEMCACHED_BEHAVIOR_SUPPORT_CAS:
+  case MEMCACHED_BEHAVIOR_NO_BLOCK:
+  case MEMCACHED_BEHAVIOR_BUFFER_REQUESTS:
+  case MEMCACHED_BEHAVIOR_USER_DATA:
+  case MEMCACHED_BEHAVIOR_SORT_HOSTS:
+  case MEMCACHED_BEHAVIOR_VERIFY_KEY:
+  case MEMCACHED_BEHAVIOR_TCP_NODELAY:
+  case MEMCACHED_BEHAVIOR_KETAMA:
+  case MEMCACHED_BEHAVIOR_CACHE_LOOKUPS:
+    if (setting.compare("1") == 0)
+    {
+      isetting= 1;
+    }
+    else if (setting.compare("0") == 0)
+    {
+      isetting= 0;
+    }
+    else
+    {
+      setFailureString("INVALID VALUE FOR BEHAVIOR - MUST be 1 OR 0!");
+      return &failure_buff;
+    }
+    break;
+  case MEMCACHED_BEHAVIOR_DISTRIBUTION:
+    isetting= dist_settings_map[setting];
+    if (! isetting)
+    {
+      setFailureString("INVALID VALUE FOR DISTRIBUTION!");
+      return &failure_buff;
+    }
+    break;
+  case MEMCACHED_BEHAVIOR_HASH:
+    isetting= hash_settings_map[setting];
+    if (! isetting)
+    {
+      setFailureString("INVALID VALUE FOR MEMCACHED HASH ALGORITHM!");
+      return &failure_buff;
+    }
+    break;
+  case MEMCACHED_BEHAVIOR_KETAMA_HASH:
+    isetting= ketama_hash_settings_map[setting];
+    if (! isetting)
+    {
+      setFailureString("INVALID VALUE FOR KETAMA HASH ALGORITHM!");
+      return &failure_buff;
+    }
+    break;
+  case MEMCACHED_BEHAVIOR_SOCKET_SEND_SIZE:
+  case MEMCACHED_BEHAVIOR_SOCKET_RECV_SIZE:
+  case MEMCACHED_BEHAVIOR_POLL_TIMEOUT:
+  case MEMCACHED_BEHAVIOR_CONNECT_TIMEOUT:
+  case MEMCACHED_BEHAVIOR_RETRY_TIMEOUT:
+  case MEMCACHED_BEHAVIOR_IO_MSG_WATERMARK:
+  case MEMCACHED_BEHAVIOR_IO_BYTES_WATERMARK:
+    /*
+      What type of check the values passed to these behaviors?
+      Range?
+    */
+    break;
+  default:
+    break;
+  }
+
+  rc= memcached_behavior_set(memc, mbehavior, isetting);
+
+  if (rc != MEMCACHED_SUCCESS)
+  {
+    return &failure_buff;
+  }
+
+  return &success_buff;
+}
+

=== added file 'plugin/memcached_udf/memc_behavior_set.h'
--- plugin/memcached_udf/memc_behavior_set.h	1970-01-01 00:00:00 +0000
+++ plugin/memcached_udf/memc_behavior_set.h	2009-07-13 03:04:57 +0000
@@ -0,0 +1,164 @@
+/* - mode: c; c-basic-offset: 2; indent-tabs-mode: nil; -*-
+ *  vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
+ *
+ *  Copyright (C) 2009 Sun Microsystems
+ *
+ *  This program is free software; you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation; either version 2 of the License, or
+ *  (at your option) any later version.
+ *
+ *  This program is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License
+ *  along with this program; if not, write to the Free Software
+ *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
+ */
+
+#ifndef MEMC_BEHAVIOR_SET_H
+#define MEMC_BEHAVIOR_SET_H
+
+#include <drizzled/server_includes.h>
+#include <drizzled/sql_udf.h>
+#include <drizzled/item/func.h>
+
+#include <libmemcached/memcached.h>
+
+#include <map>
+#include <string>
+
+/* implements memc_behavior_set */
+class MemcachedBehaviorSet : public Item_str_func
+{
+public:
+  MemcachedBehaviorSet()
+    : 
+      Item_str_func(),
+      failure_buff("FAILURE", &my_charset_bin),
+      success_buff("SUCCESS", &my_charset_bin),
+      behavior_map(),
+      dist_settings_map(),
+      hash_settings_map(),
+      ketama_hash_settings_map()
+  {
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_SUPPORT_CAS", MEMCACHED_BEHAVIOR_SUPPORT_CAS));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_NO_BLOCK", MEMCACHED_BEHAVIOR_NO_BLOCK));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_TCP_NODELAY", MEMCACHED_BEHAVIOR_TCP_NODELAY));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_HASH", MEMCACHED_BEHAVIOR_HASH));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_CACHE_LOOKUPS", MEMCACHED_BEHAVIOR_CACHE_LOOKUPS));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_SOCKET_SEND_SIZE", MEMCACHED_BEHAVIOR_SOCKET_SEND_SIZE));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_SOCKET_RECV_SIZE", MEMCACHED_BEHAVIOR_SOCKET_RECV_SIZE));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_BUFFER_REQUESTS", MEMCACHED_BEHAVIOR_BUFFER_REQUESTS));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_KETAMA", MEMCACHED_BEHAVIOR_KETAMA));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_POLL_TIMEOUT", MEMCACHED_BEHAVIOR_POLL_TIMEOUT));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_RETRY_TIMEOUT", MEMCACHED_BEHAVIOR_RETRY_TIMEOUT));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_DISTRIBUTION", MEMCACHED_BEHAVIOR_DISTRIBUTION));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_USER_DATA", MEMCACHED_BEHAVIOR_USER_DATA));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_SORT_HOSTS", MEMCACHED_BEHAVIOR_SORT_HOSTS));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_VERIFY_KEY", MEMCACHED_BEHAVIOR_VERIFY_KEY));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_CONNECT_TIMEOUT", MEMCACHED_BEHAVIOR_CONNECT_TIMEOUT));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_KETAMA_WEIGHTED", MEMCACHED_BEHAVIOR_KETAMA_WEIGHTED));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_KETAMA_HASH", MEMCACHED_BEHAVIOR_KETAMA_HASH));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_BINARY_PROTOCOL", MEMCACHED_BEHAVIOR_BINARY_PROTOCOL));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_SND_TIMEOUT", MEMCACHED_BEHAVIOR_SND_TIMEOUT));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_RCV_TIMEOUT", MEMCACHED_BEHAVIOR_RCV_TIMEOUT));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_SERVER_FAILURE_LIMIT", MEMCACHED_BEHAVIOR_SERVER_FAILURE_LIMIT));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_IO_MSG_WATERMARK", MEMCACHED_BEHAVIOR_IO_MSG_WATERMARK));
+    behavior_map.insert(std::pair<const std::string, memcached_behavior>
+      ("MEMCACHED_BEHAVIOR_IO_BYTES_WATERMARK", MEMCACHED_BEHAVIOR_IO_BYTES_WATERMARK));
+
+    dist_settings_map.insert(std::pair<const std::string, uint64_t>
+      ("MEMCACHED_DISTRIBUTION_MODULA", MEMCACHED_DISTRIBUTION_MODULA));
+    dist_settings_map.insert(std::pair<const std::string, uint64_t>
+      ("MEMCACHED_DISTRIBUTION_CONSISTENT", MEMCACHED_DISTRIBUTION_CONSISTENT));
+    dist_settings_map.insert(std::pair<const std::string, uint64_t>
+      ("MEMCACHED_DISTRIBUTION_CONSISTENT_KETAMA", MEMCACHED_DISTRIBUTION_CONSISTENT_KETAMA));
+
+    hash_settings_map.insert(std::pair<const std::string, uint64_t>
+      ("MEMCACHED_HASH_DEFAULT", MEMCACHED_HASH_DEFAULT));
+    hash_settings_map.insert(std::pair<const std::string, uint64_t>
+      ("MEMCACHED_HASH_MD5", MEMCACHED_HASH_MD5));
+    hash_settings_map.insert(std::pair<const std::string, uint64_t>
+      ("MEMCACHED_HASH_CRC", MEMCACHED_HASH_CRC));
+    hash_settings_map.insert(std::pair<const std::string, uint64_t>
+      ("MEMCACHED_HASH_FNV1_64", MEMCACHED_HASH_FNV1_64));
+    hash_settings_map.insert(std::pair<const std::string, uint64_t>
+      ("MEMCACHED_HASH_FNV1A_64", MEMCACHED_HASH_FNV1A_64));
+    hash_settings_map.insert(std::pair<const std::string, uint64_t>
+      ("MEMCACHED_HASH_FNV1_32", MEMCACHED_HASH_FNV1_32));
+    hash_settings_map.insert(std::pair<const std::string, uint64_t>
+      ("MEMCACHED_HASH_FNV1A_32", MEMCACHED_HASH_FNV1A_32));
+    hash_settings_map.insert(std::pair<const std::string, uint64_t>
+      ("MEMCACHED_HASH_JENKINS", MEMCACHED_HASH_JENKINS));
+    hash_settings_map.insert(std::pair<const std::string, uint64_t>
+      ("MEMCACHED_HASH_HSIEH", MEMCACHED_HASH_HSIEH));
+    hash_settings_map.insert(std::pair<const std::string, uint64_t>
+      ("MEMCACHED_HASH_MURMUR", MEMCACHED_HASH_MURMUR));
+
+    ketama_hash_settings_map.insert(std::pair<const std::string, uint64_t>
+      ("MEMCACHED_HASH_DEFAULT", MEMCACHED_HASH_DEFAULT));
+    ketama_hash_settings_map.insert(std::pair<const std::string, uint64_t>
+      ("MEMCACHED_HASH_MD5", MEMCACHED_HASH_MD5));
+    ketama_hash_settings_map.insert(std::pair<const std::string, uint64_t>
+      ("MEMCACHED_HASH_CRC", MEMCACHED_HASH_CRC));
+    ketama_hash_settings_map.insert(std::pair<const std::string, uint64_t>
+      ("MEMCACHED_HASH_FNV1_64", MEMCACHED_HASH_FNV1_64));
+    ketama_hash_settings_map.insert(std::pair<const std::string, uint64_t>
+      ("MEMCACHED_HASH_FNV1A_64", MEMCACHED_HASH_FNV1A_64));
+    ketama_hash_settings_map.insert(std::pair<const std::string, uint64_t>
+      ("MEMCACHED_HASH_FNV1_32", MEMCACHED_HASH_FNV1_32));
+    ketama_hash_settings_map.insert(std::pair<const std::string, uint64_t>
+      ("MEMCACHED_HASH_FNV1A_32", MEMCACHED_HASH_FNV1A_32));
+  }
+
+  const char *func_name() const
+  {
+    return "memc_behavior_set";
+  }
+
+  String *val_str(String *);
+
+  void fix_length_and_dec()
+  {
+    max_length= 32;
+  }
+
+private:
+  void setFailureString(const char *error);
+
+  String failure_buff;
+  String success_buff;
+
+  std::map<const std::string, memcached_behavior> behavior_map;
+  std::map<const std::string, uint64_t> dist_settings_map;
+  std::map<const std::string, uint64_t> hash_settings_map;
+  std::map<const std::string, uint64_t> ketama_hash_settings_map;
+};
+
+#endif /* MEMC_BEHAVIOR_SET_H */

=== added file 'plugin/memcached_udf/memc_delete.cc'
--- plugin/memcached_udf/memc_delete.cc	1970-01-01 00:00:00 +0000
+++ plugin/memcached_udf/memc_delete.cc	2009-07-12 04:13:35 +0000
@@ -0,0 +1,54 @@
+/* - mode: c; c-basic-offset: 2; indent-tabs-mode: nil; -*-
+ *  vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
+ *
+ *  Copyright (C) 2009 Sun Microsystems
+ *
+ *  This program is free software; you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation; either version 2 of the License, or
+ *  (at your option) any later version.
+ *
+ *  This program is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License
+ *  along with this program; if not, write to the Free Software
+ *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
+ */
+
+#include <drizzled/server_includes.h>
+#include <drizzled/sql_udf.h>
+#include <drizzled/function/str/strfunc.h>
+
+#include "memcached_udf.h"
+#include "memc_delete.h"
+
+#include <libmemcached/memcached.h>
+
+#include <string>
+
+using namespace std;
+
+String *MemcachedDelete::val_str(String *str)
+{
+  memcached_return rc;
+  String *key;
+
+  if (arg_count != 1 ||
+      ! (key= args[0]->val_str(str)) ||
+      ! memc)
+  {
+    return &failure_buff;
+  }
+
+  rc= memcached_delete(memc, key->c_ptr(), key->length(), 0);
+  if (rc != MEMCACHED_SUCCESS)
+  {
+    return &failure_buff;
+  }
+
+  return &success_buff;
+}
+

=== added file 'plugin/memcached_udf/memc_delete.h'
--- plugin/memcached_udf/memc_delete.h	1970-01-01 00:00:00 +0000
+++ plugin/memcached_udf/memc_delete.h	2009-07-12 04:13:35 +0000
@@ -0,0 +1,56 @@
+/* - mode: c; c-basic-offset: 2; indent-tabs-mode: nil; -*-
+ *  vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
+ *
+ *  Copyright (C) 2009 Sun Microsystems
+ *
+ *  This program is free software; you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation; either version 2 of the License, or
+ *  (at your option) any later version.
+ *
+ *  This program is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License
+ *  along with this program; if not, write to the Free Software
+ *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
+ */
+
+#ifndef MEMC_DELETE_H
+#define MEMC_DELETE_H
+
+#include <drizzled/server_includes.h>
+#include <drizzled/sql_udf.h>
+#include <drizzled/function/str/strfunc.h>
+
+/* implements memc_delete */
+class MemcachedDelete : public Item_str_func
+{
+public:
+  MemcachedDelete()
+    : 
+      Item_str_func(),
+      failure_buff("FAILURE", &my_charset_bin),
+      success_buff("SUCCESS", &my_charset_bin)
+  {}
+
+  const char *func_name() const
+  {
+    return "memc_delete";
+  }
+
+  String *val_str(String *);
+
+  void fix_length_and_dec()
+  {
+    max_length= 32;
+  }
+
+private:
+  String failure_buff;
+  String success_buff;
+};
+
+#endif /* MEMC_DELETE_H */

=== added file 'plugin/memcached_udf/memc_get.cc'
--- plugin/memcached_udf/memc_get.cc	1970-01-01 00:00:00 +0000
+++ plugin/memcached_udf/memc_get.cc	2009-07-12 04:13:35 +0000
@@ -0,0 +1,60 @@
+/* - mode: c; c-basic-offset: 2; indent-tabs-mode: nil; -*-
+ *  vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
+ *
+ *  Copyright (C) 2009 Sun Microsystems
+ *
+ *  This program is free software; you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation; either version 2 of the License, or
+ *  (at your option) any later version.
+ *
+ *  This program is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License
+ *  along with this program; if not, write to the Free Software
+ *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
+ */
+
+#include <drizzled/server_includes.h>
+#include <drizzled/sql_udf.h>
+#include <drizzled/function/str/strfunc.h>
+
+#include "memcached_udf.h"
+#include "memc_get.h"
+
+#include <libmemcached/memcached.h>
+
+#include <string>
+
+using namespace std;
+
+String *MemcachedGet::val_str(String *str)
+{
+  memcached_return rc;
+  String *key;
+  uint32_t flags;
+  size_t val_len;
+
+  if (arg_count != 1 ||
+      ! (key= args[0]->val_str(str)) ||
+      ! memc)
+  {
+    return &failure_buff;
+  }
+
+  char *value= memcached_get(memc, key->c_ptr(), key->length(), &val_len, &flags, &rc);
+  if (rc != MEMCACHED_SUCCESS)
+  {
+    return &failure_buff;
+  }
+
+  buffer.realloc(val_len);
+  buffer.length(val_len);
+  memcpy(buffer.ptr(), value, val_len);
+
+  return &buffer;
+}
+

=== added file 'plugin/memcached_udf/memc_get.h'
--- plugin/memcached_udf/memc_get.h	1970-01-01 00:00:00 +0000
+++ plugin/memcached_udf/memc_get.h	2009-07-12 04:13:35 +0000
@@ -0,0 +1,55 @@
+/* - mode: c; c-basic-offset: 2; indent-tabs-mode: nil; -*-
+ *  vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
+ *
+ *  Copyright (C) 2009 Sun Microsystems
+ *
+ *  This program is free software; you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation; either version 2 of the License, or
+ *  (at your option) any later version.
+ *
+ *  This program is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License
+ *  along with this program; if not, write to the Free Software
+ *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
+ */
+
+#ifndef MEMC_GET_H
+#define MEMC_GET_H
+
+#include <drizzled/server_includes.h>
+#include <drizzled/sql_udf.h>
+#include <drizzled/function/str/strfunc.h>
+
+/* implements memc_get */
+class MemcachedGet : public Item_str_func
+{
+public:
+  MemcachedGet()
+    : 
+      Item_str_func(),
+      failure_buff("FAILURE", &my_charset_bin)
+  {}
+
+  const char *func_name() const
+  {
+    return "memc_get";
+  }
+
+  String *val_str(String *);
+
+  void fix_length_and_dec()
+  {
+    max_length= 32;
+  }
+
+private:
+  String failure_buff;
+  String buffer;
+};
+
+#endif /* MEMC_GET_H */

=== added file 'plugin/memcached_udf/memc_misc.cc'
--- plugin/memcached_udf/memc_misc.cc	1970-01-01 00:00:00 +0000
+++ plugin/memcached_udf/memc_misc.cc	2009-07-12 04:13:35 +0000
@@ -0,0 +1,59 @@
+/* - mode: c; c-basic-offset: 2; indent-tabs-mode: nil; -*-
+ *  vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
+ *
+ *  Copyright (C) 2009 Sun Microsystems
+ *
+ *  This program is free software; you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation; either version 2 of the License, or
+ *  (at your option) any later version.
+ *
+ *  This program is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License
+ *  along with this program; if not, write to the Free Software
+ *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
+ */
+
+#include <drizzled/server_includes.h>
+#include <drizzled/sql_udf.h>
+#include <drizzled/function/str/strfunc.h>
+
+#include "memcached_udf.h"
+#include "memc_misc.h"
+
+#include <libmemcached/memcached.h>
+
+#include <string>
+
+using namespace std;
+
+String *MemcachedVersion::val_str(String*)
+{
+  if (! memc)
+  {
+    return &failure_buff;
+  }
+
+  const char *version= memcached_lib_version();
+  size_t ver_len= strlen(version);
+
+  buffer.realloc(ver_len);
+  buffer.length(ver_len);
+  memcpy(buffer.ptr(), version, ver_len);
+
+  return &buffer;
+}
+
+int64_t MemcachedServerCount::val_int()
+{
+  if (! memc)
+  {
+    return 0;
+  }
+  
+  return (memcached_server_count(memc));
+}

=== added file 'plugin/memcached_udf/memc_misc.h'
--- plugin/memcached_udf/memc_misc.h	1970-01-01 00:00:00 +0000
+++ plugin/memcached_udf/memc_misc.h	2009-07-12 04:13:35 +0000
@@ -0,0 +1,80 @@
+/* - mode: c; c-basic-offset: 2; indent-tabs-mode: nil; -*-
+ *  vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
+ *
+ *  Copyright (C) 2009 Sun Microsystems
+ *
+ *  This program is free software; you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation; either version 2 of the License, or
+ *  (at your option) any later version.
+ *
+ *  This program is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License
+ *  along with this program; if not, write to the Free Software
+ *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
+ */
+
+#ifndef MEMC_MISC_H
+#define MEMC_MISC_H
+
+#include <drizzled/server_includes.h>
+#include <drizzled/sql_udf.h>
+#include <drizzled/item/func.h>
+#include <drizzled/function/str/strfunc.h>
+
+/* implements memc_libmemcached_version */
+class MemcachedVersion : public Item_str_func
+{
+public:
+  MemcachedVersion()
+    : 
+      Item_str_func(),
+      failure_buff("FAILURE", &my_charset_bin)
+  {}
+
+  const char *func_name() const
+  {
+    return "memc_libmemcached_version";
+  }
+
+  String *val_str(String *);
+
+  void fix_length_and_dec()
+  {
+    max_length= 32;
+  }
+
+private:
+  String buffer;
+  String failure_buff;
+};
+
+/* implements memc_server_count */
+class MemcachedServerCount : public Item_int_func
+{
+public:
+  MemcachedServerCount()
+    :
+      Item_int_func()
+  {
+    unsigned_flag= 1;
+  }
+
+  const char *func_name() const
+  {
+    return "memc_server_count";
+  }
+
+  void fix_length_and_dec()
+  {
+    max_length= 10;
+  }
+
+  int64_t val_int();
+};
+
+#endif /* MEMC_MISC_H */

=== added file 'plugin/memcached_udf/memc_prepend.cc'
--- plugin/memcached_udf/memc_prepend.cc	1970-01-01 00:00:00 +0000
+++ plugin/memcached_udf/memc_prepend.cc	2009-07-12 04:13:35 +0000
@@ -0,0 +1,57 @@
+/* - mode: c; c-basic-offset: 2; indent-tabs-mode: nil; -*-
+ *  vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
+ *
+ *  Copyright (C) 2009 Sun Microsystems
+ *
+ *  This program is free software; you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation; either version 2 of the License, or
+ *  (at your option) any later version.
+ *
+ *  This program is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License
+ *  along with this program; if not, write to the Free Software
+ *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
+ */
+
+#include <drizzled/server_includes.h>
+#include <drizzled/sql_udf.h>
+#include <drizzled/function/str/strfunc.h>
+
+#include "memcached_udf.h"
+#include "memc_prepend.h"
+
+#include <libmemcached/memcached.h>
+
+#include <string>
+
+using namespace std;
+
+String *MemcachedPrepend::val_str(String *str)
+{
+  memcached_return rc;
+  String *key;
+  String *value;
+
+  if (arg_count != 2 ||
+      ! (key= args[0]->val_str(str)) ||
+      ! (value= args[1]->val_str(str)) ||
+      ! memc)
+  {
+    return &failure_buff;
+  }
+
+  rc= memcached_prepend(memc, key->c_ptr(), key->length(),
+                       value->c_ptr(), value->length(), 0, 0);
+  if (rc != MEMCACHED_SUCCESS)
+  {
+    return &failure_buff;
+  }
+
+  return &success_buff;
+}
+

=== added file 'plugin/memcached_udf/memc_prepend.h'
--- plugin/memcached_udf/memc_prepend.h	1970-01-01 00:00:00 +0000
+++ plugin/memcached_udf/memc_prepend.h	2009-07-12 04:13:35 +0000
@@ -0,0 +1,56 @@
+/* - mode: c; c-basic-offset: 2; indent-tabs-mode: nil; -*-
+ *  vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
+ *
+ *  Copyright (C) 2009 Sun Microsystems
+ *
+ *  This program is free software; you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation; either version 2 of the License, or
+ *  (at your option) any later version.
+ *
+ *  This program is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License
+ *  along with this program; if not, write to the Free Software
+ *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
+ */
+
+#ifndef MEMC_PREPEND_H
+#define MEMC_PREPEND_H
+
+#include <drizzled/server_includes.h>
+#include <drizzled/sql_udf.h>
+#include <drizzled/function/str/strfunc.h>
+
+/* implements memc_prepend */
+class MemcachedPrepend : public Item_str_func
+{
+public:
+  MemcachedPrepend()
+    : 
+      Item_str_func(),
+      failure_buff("FAILURE", &my_charset_bin),
+      success_buff("SUCCESS", &my_charset_bin)
+  {}
+
+  const char *func_name() const
+  {
+    return "memc_prepend";
+  }
+
+  String *val_str(String *);
+
+  void fix_length_and_dec()
+  {
+    max_length= 32;
+  }
+
+private:
+  String failure_buff;
+  String success_buff;
+};
+
+#endif /* MEMC_PREPEND_H */

=== added file 'plugin/memcached_udf/memc_servers_set.cc'
--- plugin/memcached_udf/memc_servers_set.cc	1970-01-01 00:00:00 +0000
+++ plugin/memcached_udf/memc_servers_set.cc	2009-07-12 04:13:35 +0000
@@ -0,0 +1,62 @@
+/* - mode: c; c-basic-offset: 2; indent-tabs-mode: nil; -*-
+ *  vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
+ *
+ *  Copyright (C) 2009 Sun Microsystems
+ *
+ *  This program is free software; you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation; either version 2 of the License, or
+ *  (at your option) any later version.
+ *
+ *  This program is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License
+ *  along with this program; if not, write to the Free Software
+ *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
+ */
+
+#include <drizzled/server_includes.h>
+#include <drizzled/sql_udf.h>
+#include <drizzled/item/func.h>
+#include <drizzled/function/str/strfunc.h>
+
+#include "memcached_udf.h"
+#include "memc_servers_set.h"
+
+#include <libmemcached/memcached.h>
+
+#include <string>
+
+using namespace std;
+
+String *MemcachedServersSet::val_str(String *str)
+{
+  memcached_return rc;
+  memcached_server_st *servers;
+  String *server_names;
+
+  if (arg_count != 1 ||
+      ! (server_names= args[0]->val_str(str)) ||
+      ! memc)
+  {
+    return &failure_buff;
+  }
+
+  servers= memcached_servers_parse(server_names->c_ptr());
+  if (servers == NULL)
+  {
+    return &failure_buff;
+  }
+
+  rc= memcached_server_push(memc, servers);
+  if (rc != MEMCACHED_SUCCESS)
+  {
+    return &failure_buff;
+  }
+
+  return &success_buff;
+}
+

=== added file 'plugin/memcached_udf/memc_servers_set.h'
--- plugin/memcached_udf/memc_servers_set.h	1970-01-01 00:00:00 +0000
+++ plugin/memcached_udf/memc_servers_set.h	2009-07-12 04:13:35 +0000
@@ -0,0 +1,60 @@
+/* - mode: c; c-basic-offset: 2; indent-tabs-mode: nil; -*-
+ *  vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
+ *
+ *  Copyright (C) 2009 Sun Microsystems
+ *
+ *  This program is free software; you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation; either version 2 of the License, or
+ *  (at your option) any later version.
+ *
+ *  This program is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License
+ *  along with this program; if not, write to the Free Software
+ *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
+ */
+
+#ifndef MEMC_SERVERS_SET_H
+#define MEMC_SERVERS_SET_H
+
+#include <drizzled/server_includes.h>
+#include <drizzled/sql_udf.h>
+#include <drizzled/item/func.h>
+
+/* implements memc_servers_set */
+class MemcachedServersSet : public Item_str_func
+{
+public:
+  MemcachedServersSet()
+    : 
+      Item_str_func(),
+      failure_buff("FAILURE", &my_charset_bin),
+      success_buff("SUCCESS", &my_charset_bin)
+  {}
+
+  const char *func_name() const
+  {
+    return "memc_servers_set";
+  }
+
+  String *val_str(String *);
+
+  void fix_length_and_dec()
+  {
+    max_length= 32;
+    args[0]->collation.set(
+      get_charset_by_csname(args[0]->collation.collation->csname,
+                            MY_CS_BINSORT),
+      DERIVATION_COERCIBLE);
+  }
+
+private:
+  String failure_buff;
+  String success_buff;
+};
+
+#endif /* MEMC_SERVERS_SET_H */

=== added file 'plugin/memcached_udf/memc_set.cc'
--- plugin/memcached_udf/memc_set.cc	1970-01-01 00:00:00 +0000
+++ plugin/memcached_udf/memc_set.cc	2009-07-12 04:13:35 +0000
@@ -0,0 +1,58 @@
+/* - mode: c; c-basic-offset: 2; indent-tabs-mode: nil; -*-
+ *  vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
+ *
+ *  Copyright (C) 2009 Sun Microsystems
+ *
+ *  This program is free software; you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation; either version 2 of the License, or
+ *  (at your option) any later version.
+ *
+ *  This program is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License
+ *  along with this program; if not, write to the Free Software
+ *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
+ */
+
+#include <drizzled/server_includes.h>
+#include <drizzled/sql_udf.h>
+#include <drizzled/function/str/strfunc.h>
+
+#include "memcached_udf.h"
+#include "memc_set.h"
+
+#include <libmemcached/memcached.h>
+
+#include <string>
+
+using namespace std;
+
+String *MemcachedSet::val_str(String *str)
+{
+  memcached_return rc;
+  String *key;
+  String *value;
+
+  if (arg_count != 2 ||
+      ! (key= args[0]->val_str(str)) ||
+      ! (value= args[1]->val_str(str)) ||
+      ! memc)
+  {
+    return &failure_buff;
+  }
+
+  rc= memcached_set(memc, key->c_ptr(), key->length(),
+                    value->c_ptr(), value->length(),
+                    0, 0);
+  if (rc != MEMCACHED_SUCCESS)
+  {
+    return &failure_buff;
+  }
+
+  return &success_buff;
+}
+

=== added file 'plugin/memcached_udf/memc_set.h'
--- plugin/memcached_udf/memc_set.h	1970-01-01 00:00:00 +0000
+++ plugin/memcached_udf/memc_set.h	2009-07-12 04:13:35 +0000
@@ -0,0 +1,56 @@
+/* - mode: c; c-basic-offset: 2; indent-tabs-mode: nil; -*-
+ *  vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
+ *
+ *  Copyright (C) 2009 Sun Microsystems
+ *
+ *  This program is free software; you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation; either version 2 of the License, or
+ *  (at your option) any later version.
+ *
+ *  This program is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License
+ *  along with this program; if not, write to the Free Software
+ *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
+ */
+
+#ifndef MEMC_SET_H
+#define MEMC_SET_H
+
+#include <drizzled/server_includes.h>
+#include <drizzled/sql_udf.h>
+#include <drizzled/function/str/strfunc.h>
+
+/* implements memc_set */
+class MemcachedSet : public Item_str_func
+{
+public:
+  MemcachedSet()
+    : 
+      Item_str_func(),
+      failure_buff("FAILURE", &my_charset_bin),
+      success_buff("SUCCESS", &my_charset_bin)
+  {}
+
+  const char *func_name() const
+  {
+    return "memc_set";
+  }
+
+  String *val_str(String *);
+
+  void fix_length_and_dec()
+  {
+    max_length= 32;
+  }
+
+private:
+  String failure_buff;
+  String success_buff;
+};
+
+#endif /* MEMC_SET_H */

=== added file 'plugin/memcached_udf/memcached_udf.cc'
--- plugin/memcached_udf/memcached_udf.cc	1970-01-01 00:00:00 +0000
+++ plugin/memcached_udf/memcached_udf.cc	2009-07-13 14:02:39 +0000
@@ -0,0 +1,208 @@
+/* - mode: c; c-basic-offset: 2; indent-tabs-mode: nil; -*-
+ *  vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
+ *
+ *  Copyright (C) 2009 Sun Microsystems
+ *
+ *  This program is free software; you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation; either version 2 of the License, or
+ *  (at your option) any later version.
+ *
+ *  This program is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License
+ *  along with this program; if not, write to the Free Software
+ *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
+ */
+
+#include <drizzled/server_includes.h>
+#include <drizzled/sql_udf.h>
+#include <drizzled/item/func.h>
+#include <drizzled/function/str/strfunc.h>
+
+#include "memcached_udf.h"
+#include "memc_servers_set.h"
+#include "memc_behavior_set.h"
+#include "memc_behavior_get.h"
+#include "memc_get.h"
+#include "memc_set.h"
+#include "memc_delete.h"
+#include "memc_append.h"
+#include "memc_prepend.h"
+#include "memc_misc.h"
+
+#include <libmemcached/memcached.h>
+
+#include <string>
+
+using namespace std;
+
+/*
+ * A global memcached data structure needed by
+ * the various libmemcached API functions.
+ */
+memcached_st *memc= NULL;
+
+/*
+ * The memcached UDF's.
+ */
+static Create_function<MemcachedServersSet> *memc_servers_set= NULL;
+static Create_function<MemcachedBehaviorSet> *memc_behavior_set= NULL;
+static Create_function<MemcachedBehaviorGet> *memc_behavior_get= NULL;
+static Create_function<MemcachedGet> *memc_get= NULL;
+static Create_function<MemcachedSet> *memc_set= NULL;
+static Create_function<MemcachedDelete> *memc_delete= NULL;
+static Create_function<MemcachedAppend> *memc_append= NULL;
+static Create_function<MemcachedPrepend> *memc_prepend= NULL;
+static Create_function<MemcachedServerCount> *memc_serv_count= NULL;
+static Create_function<MemcachedVersion> *memc_version= NULL;
+
+bool initMemcUDF()
+{
+  memc_servers_set= new(std::nothrow)
+    Create_function<MemcachedServersSet>(string("memc_servers_set"));
+  if (memc_servers_set == NULL)
+  {
+    return true;
+  }
+
+  memc_behavior_set= new(std::nothrow)
+    Create_function<MemcachedBehaviorSet>(string("memc_behavior_set"));
+  if (memc_behavior_set == NULL)
+  {
+    return true;
+  }
+
+  memc_behavior_get= new(std::nothrow)
+    Create_function<MemcachedBehaviorGet>(string("memc_behavior_get"));
+  if (memc_behavior_get == NULL)
+  {
+    return true;
+  }
+
+  memc_get= new(std::nothrow)
+    Create_function<MemcachedGet>(string("memc_get"));
+  if (memc_get == NULL)
+  {
+    return true;
+  }
+
+  memc_set= new(std::nothrow)
+    Create_function<MemcachedSet>(string("memc_set"));
+  if (memc_set == NULL)
+  {
+    return true;
+  }
+
+  memc_delete= new(std::nothrow)
+    Create_function<MemcachedDelete>(string("memc_delete"));
+  if (memc_delete == NULL)
+  {
+    return true;
+  }
+
+  memc_append= new(std::nothrow)
+    Create_function<MemcachedAppend>(string("memc_append"));
+  if (memc_append == NULL)
+  {
+    return true;
+  }
+
+  memc_prepend= new(std::nothrow)
+    Create_function<MemcachedPrepend>(string("memc_prepend"));
+  if (memc_prepend == NULL)
+  {
+    return true;
+  }
+
+  memc_serv_count= new(std::nothrow)
+    Create_function<MemcachedServerCount>(string("memc_server_count"));
+  if (memc_serv_count == NULL)
+  {
+    return true;
+  }
+
+  memc_version= new(std::nothrow)
+    Create_function<MemcachedVersion>(string("memc_libmemcached_version"));
+  if (memc_version == NULL)
+  {
+    return true;
+  }
+
+  return false;
+}
+
+void cleanupMemcUDF()
+{
+  delete memc_servers_set;
+  delete memc_behavior_set;
+  delete memc_behavior_get;
+  delete memc_get;
+  delete memc_set;
+  delete memc_delete;
+  delete memc_append;
+  delete memc_prepend;
+  delete memc_serv_count;
+  delete memc_version;
+}
+
+static int memcachedInit(PluginRegistry &registry)
+{
+  if (initMemcUDF())
+  {
+    return 1;
+  }
+
+  memc= memcached_create(NULL);
+
+  registry.add(memc_servers_set);
+  registry.add(memc_behavior_set);
+  registry.add(memc_behavior_get);
+  registry.add(memc_get);
+  registry.add(memc_set);
+  registry.add(memc_delete);
+  registry.add(memc_append);
+  registry.add(memc_prepend);
+  registry.add(memc_serv_count);
+  registry.add(memc_version);
+
+  return 0;
+}
+
+static int memcachedDone(PluginRegistry &registry)
+{
+  cleanupMemcUDF();
+
+  memcached_free(memc);
+
+  registry.remove(memc_servers_set);
+  registry.remove(memc_behavior_set);
+  registry.remove(memc_behavior_get);
+  registry.remove(memc_get);
+  registry.remove(memc_set);
+  registry.remove(memc_delete);
+  registry.remove(memc_append);
+  registry.remove(memc_prepend);
+  registry.remove(memc_serv_count);
+  registry.remove(memc_version);
+
+  return 0;
+}
+
+drizzle_declare_plugin(memcached_udf)
+{
+  "memcached_udf",
+  "0.1",
+  "Patrick Galbraith, Ronald Bradford, Padraig O'Sullivan",
+  "Memcached UDF Plugin",
+  PLUGIN_LICENSE_GPL,
+  memcachedInit,
+  memcachedDone,
+  NULL,
+  NULL,
+  NULL
+}
+drizzle_declare_plugin_end;

=== added file 'plugin/memcached_udf/memcached_udf.h'
--- plugin/memcached_udf/memcached_udf.h	1970-01-01 00:00:00 +0000
+++ plugin/memcached_udf/memcached_udf.h	2009-07-12 04:13:35 +0000
@@ -0,0 +1,41 @@
+/* - mode: c; c-basic-offset: 2; indent-tabs-mode: nil; -*-
+ *  vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
+ *
+ *  Copyright (C) 2009 Sun Microsystems
+ *
+ *  This program is free software; you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation; either version 2 of the License, or
+ *  (at your option) any later version.
+ *
+ *  This program is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License
+ *  along with this program; if not, write to the Free Software
+ *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
+ */
+
+#ifndef MEMCACHED_UDF_H
+#define MEMCACHED_UDF_H
+
+#include <libmemcached/memcached.h>
+
+extern memcached_st *memc;
+
+/**
+ * Initialize all the UDF functions for memcached.
+ *
+ * @return false on success; true on failure
+ */
+bool initMemcUDF();
+
+/**
+ * Release all memory allocated for the memcached
+ * UDF's.
+ */
+void cleanupMemcUDF();
+
+#endif /* MEMCACHED_UDF_H */

=== added file 'plugin/memcached_udf/plugin.ac'
--- plugin/memcached_udf/plugin.ac	1970-01-01 00:00:00 +0000
+++ plugin/memcached_udf/plugin.ac	2009-07-12 04:13:35 +0000
@@ -0,0 +1,9 @@
+AC_LIB_HAVE_LINKFLAGS(memcached,,
+  [#include <libmemcached/memcached.h>],
+  [
+    memcached_st memc;
+    memcached_lib_version();
+  ])
+AS_IF([test "x$ac_cv_libmemcached" = "xno"],
+      AC_MSG_WARN([libmemcached not found: not building memcached_udf plugin.]))
+DRIZZLED_PLUGIN_DEP_LIBS="${DRIZZLED_PLUGIN_DEP_LIBS} ${LTLIBMEMCACHED}"

=== added file 'plugin/memcached_udf/plugin.ini'
--- plugin/memcached_udf/plugin.ini	1970-01-01 00:00:00 +0000
+++ plugin/memcached_udf/plugin.ini	2009-07-13 14:02:39 +0000
@@ -0,0 +1,13 @@
+[plugin]
+name=memcached_udf
+title=Memcached Client UDFs
+description=UDF plugin for libmemcached
+load_by_default=yes
+headers=memcached_udf.h memc_get.h memc_set.h memc_delete.h memc_append.h 
+        memc_prepend.h memc_misc.h memc_servers_set.h memc_behavior_set.h
+        memc_behavior_get.h
+sources=memcached_udf.cc memc_get.cc memc_set.cc memc_delete.cc 
+        memc_append.cc memc_prepend.cc memc_misc.cc memc_servers_set.cc
+        memc_behavior_set.cc memc_behavior_get.cc
+build_conditional="${ac_cv_libmemcached}" = "yes"
+ldflags=${LTLIBMEMCACHED}