[CUBVEC-24] Convert CHAR types to DB Vector in tp_value_cast

src/compat/db_set.c

@@ -296,6 +296,66 @@ db_seq_create (MOP classop, const char *name, int size)
   return (set);
 }
 
+/*
+ * db_vec_create() - This function creates an empty vector. The class and
+ *    name arguments can be set to NULL. If values are supplied, a check will
+ *    be made to make sure that the attribute was defined with the vector
+ *    domain.
+ * return : a set (vector) descriptor
+ * classop(in): class or instance
+ * name(in): attribute name
+ * size(in): initial size
+ *
+ * note : The new set will not be attached to any object, so you must use the
+ *    db_put( ) function to assign it as the value of an attribute. If the size
+ *    is not known, it is permissible to pass zero.
+ */
+DB_SET *
+db_vec_create (MOP classop, const char *name, int size)
+{
+  DB_SET *set;
+#if !defined(SERVER_MODE)
+  int error = NO_ERROR;
+#endif
+
+  CHECK_CONNECT_NULL ();
+
+  set = NULL;
+  if (classop == NULL || name == NULL)
+    {
+      set = set_create_vector (size);
+    }
+  else
+    {
+#if !defined(SERVER_MODE)
+      SM_CLASS *class_;
+      SM_ATTRIBUTE *att;
+
+      if (au_fetch_class (classop, &class_, AU_FETCH_READ, AU_SELECT) == NO_ERROR)
+	{
+	  att = classobj_find_attribute (class_, name, 0);
+	  if (att == NULL)
+	    {
+	      ERROR_SET1 (error, ER_OBJ_INVALID_ATTRIBUTE, name);
+	    }
+	  else
+	    {
+	      if (att->type->id == DB_TYPE_VECTOR)
+		{
+		  set = set_create_vector (size);
+		}
+	      else
+		{
+		  ERROR_SET1 (error, ER_OBJ_DOMAIN_CONFLICT, name);
+		}
+	    }
+	}
+#endif
+    }
+
+  return (set);
+}
+
 /*
  * db_set_free() - This function frees a set handle. If the set is owned by an
  *    object, the contents of the set are not freed, only the set handle is

src/compat/db_set_function.h

@@ -36,6 +36,7 @@ extern "C"
   extern DB_COLLECTION *db_set_create_basic (DB_OBJECT * classobj, const char *name);
   extern DB_COLLECTION *db_set_create_multi (DB_OBJECT * classobj, const char *name);
   extern DB_COLLECTION *db_seq_create (DB_OBJECT * classobj, const char *name, int size);
+  extern DB_COLLECTION *db_vec_create (DB_OBJECT * classobj, const char *name, int size);
   extern int db_set_free (DB_COLLECTION * set);
   extern int db_set_filter (DB_COLLECTION * set);
   extern int db_set_add (DB_COLLECTION * set, DB_VALUE * value);

src/object/object_domain.c

@@ -611,6 +611,7 @@ static DB_BIGINT tp_ubi_to_bi_with_args (UINT64 ubi, bool is_negative, bool trun
 					 DB_DATA_STATUS * data_stat);
 
 static UINT64 tp_ubi_times_ten (UINT64 ubi, bool * truncated);
+static int tp_str_to_vector (DB_VALUE const *src, DB_VALUE * result);
 
 /*
  * tp_init - Global initialization for this module.
@@ -4994,6 +4995,154 @@ tp_atof (const DB_VALUE * src, double *num_value, DB_DATA_STATUS * data_stat)
   return status;
 }
 
+/*
+ * tp_str_to_vector - Coerce a string to a vector.
+ *    return: NO_ERROR or error code.
+ *    src(in): string DB_VALUE
+ *    result(out): vector DB_VALUE
+ * Note:
+ *    Accepts strings that are not null terminated. Don't call this unless
+ *    src is a string db_value.
+ */
+static int
+tp_str_to_vector (const DB_VALUE * src, DB_VALUE * result)
+{
+  const char *p = db_get_string (src);
+  const char *end = p + db_get_string_size (src);
+  int count = 0;
+  const int number_buffer_size = 64;
+  char number_buffer[number_buffer_size];
+  int buffer_idx;
+  const int max_vector_size = 2000;
+  float float_array[max_vector_size];
+  DB_SET *vec = NULL;
+  DB_VALUE e_val;
+  INTL_CODESET codeset = db_get_string_codeset (src);
+
+  if (p == NULL)
+    {
+      return ER_FAILED;
+    }
+
+  // Skip leading spaces and opening bracket
+  p = (char *) intl_skip_spaces (p, end, codeset);
+  if (p >= end || *p != '[')
+    {
+      return ER_FAILED;
+    }
+  p++;
+
+  while (p < end && count < max_vector_size)
+    {
+      // Skip spaces before number
+      p = (char *) intl_skip_spaces (p, end, codeset);
+      if (p >= end)
+	{
+	  return ER_FAILED;
+	}
+
+      // Check for closing bracket
+      if (*p == ']')
+	{
+	  break;
+	}
+
+      // Get number into buffer
+      buffer_idx = 0;
+      while (p < end && *p != ',' && *p != ']' && buffer_idx < number_buffer_size - 1)
+	{
+	  if (!isspace (*p))
+	    {
+	      number_buffer[buffer_idx++] = *p;
+	    }
+	  p++;
+	}
+
+      if (buffer_idx == 0 || buffer_idx >= number_buffer_size - 1)
+	{
+
+	  return ER_FAILED;
+	}
+
+      number_buffer[buffer_idx] = '\0';
+
+      // Convert to float
+      char *end_ptr = NULL;
+      errno = 0;
+      float_array[count] = strtof (number_buffer, &end_ptr);
+
+      if (errno == ERANGE)
+	{
+	  return ER_FAILED;
+	}
+
+      if (*end_ptr != '\0')
+	{
+	  return ER_FAILED;
+	}
+
+      count++;
+
+      // Skip spaces after number
+      p = (char *) intl_skip_spaces (p, end, codeset);
+      if (p >= end)
+	{
+	  return ER_FAILED;
+	}
+
+      // Must be comma or closing bracket
+      if (*p == ']')
+	{
+	  break;
+	}
+      else if (*p != ',')
+	{
+	  return ER_FAILED;
+	}
+      p++;
+    }
+
+  // Check for closing bracket
+  if (p >= end || *p != ']')
+    {
+      return ER_FAILED;
+    }
+  p++;
+
+  // Skip trailing spaces
+  p = (char *) intl_skip_spaces (p, end, codeset);
+  if (p != end)
+    {
+      return ER_FAILED;
+    }
+
+  if (count == 0)
+    {
+      return ER_FAILED;
+    }
+
+  // Create vector and populate it
+  vec = db_vec_create (NULL, NULL, 0);
+  if (vec == NULL)
+    {
+      assert (er_errid () != NO_ERROR);
+      return er_errid ();
+    }
+
+  db_make_vector (result, vec);
+
+  for (int i = 0; i < count; ++i)
+    {
+      db_make_float (&e_val, float_array[i]);
+      if (db_seq_put (db_get_set (result), i, &e_val) != NO_ERROR)
+	{
+	  return ER_FAILED;
+	}
+    }
+
+  return NO_ERROR;
+}
+
 /*
  * tp_atobi - Coerce a string to a bigint.
  *    return: NO_ERROR or error code
@@ -9125,6 +9274,24 @@ tp_value_cast_internal (const DB_VALUE * src, DB_VALUE * dest, const TP_DOMAIN *
 	}
       break;
 
+    case DB_TYPE_VECTOR:
+      switch (original_type)
+	{
+	case DB_TYPE_CHAR:
+	case DB_TYPE_VARCHAR:
+	case DB_TYPE_NCHAR:
+	case DB_TYPE_VARNCHAR:
+	  {
+
+	    err = tp_str_to_vector (src, target);
+	    break;
+
+	  }
+	default:
+	  status = DOMAIN_INCOMPATIBLE;
+	  break;
+	}
+      break;
     case DB_TYPE_VOBJ:
       if (original_type == DB_TYPE_VOBJ)
 	{