Adding upstream version 1:10.11.6.upstream/1%10.11.6

Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>

1 files changed, 73 insertions, 0 deletions

diff --git a/storage/myisammrg/myrg_create.c b/storage/myisammrg/myrg_create.c
new file mode 100644
index 00000000..67e94f1d
--- /dev/null
+++ b/storage/myisammrg/myrg_create.c
@@ -0,0 +1,73 @@
+/* Copyright (c) 2000, 2001, 2005-2007 MySQL AB, 2009 Sun Microsystems, Inc.
+   Use is subject to license terms.
+
+   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; version 2 of the License.
+
+   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-1335  USA */
+
+/* Create a MYMERGE_-file */
+
+#include "myrg_def.h"
+
+	/* create file named 'name' and save filenames in it
+	   table_names should be NULL or a vector of string-pointers with
+	   a NULL-pointer last
+	   */
+
+int myrg_create(const char *name, const char **table_names,
+                uint insert_method, my_bool fix_names)
+{
+  int save_errno;
+  uint errpos;
+  File file;
+  char buff[FN_REFLEN],*end;
+  DBUG_ENTER("myrg_create");
+
+  errpos=0;
+  if ((file= mysql_file_create(rg_key_file_MRG, name, 0,
+                               O_RDWR | O_EXCL | O_NOFOLLOW, MYF(MY_WME))) < 0)
+    goto err;
+  errpos=1;
+  if (table_names)
+  {
+    for ( ; *table_names ; table_names++)
+    {
+      strmov(buff,*table_names);
+      if (fix_names)
+	fn_same(buff,name,4);
+      *(end=strend(buff))='\n';
+      end[1]=0;
+      if (mysql_file_write(file, (uchar*) buff, (uint) (end-buff+1),
+                           MYF(MY_WME | MY_NABP)))
+	goto err;
+    }
+  }
+  if (insert_method != MERGE_INSERT_DISABLED)
+  {
+    end=strxmov(buff,"#INSERT_METHOD=",
+		get_type(&merge_insert_method,insert_method-1),"\n",NullS);
+    if (mysql_file_write(file, (uchar*) buff, (uint) (end-buff),
+                         MYF(MY_WME | MY_NABP)))
+        goto err;
+  }
+  if (mysql_file_close(file, MYF(0)))
+    goto err;
+  DBUG_RETURN(0);
+
+err:
+  save_errno=my_errno ? my_errno : -1;
+  switch (errpos) {
+  case 1:
+    (void) mysql_file_close(file, MYF(0));
+  }
+  DBUG_RETURN(my_errno=save_errno);
+} /* myrg_create */