Chore/2024 09 added connection test

module/ldbc-connector/shared/src/main/scala/ldbc/connector/Connection.scala

@@ -60,7 +60,7 @@ object Connection:
     socketOptions:           List[SocketOption] = defaultSocketOptions,
     readTimeout:             Duration = Duration.Inf,
     allowPublicKeyRetrieval: Boolean = false,
-    databaseTerm:            Option[DatabaseMetaData.DatabaseTerm] = None
+    databaseTerm:            Option[DatabaseMetaData.DatabaseTerm] = Some(DatabaseMetaData.DatabaseTerm.CATALOG)
   ): Tracer[F] ?=> Resource[F, LdbcConnection[F]] =
 
     val logger: String => F[Unit] = s => Console[F].println(s"TLS: $s")

module/ldbc-connector/shared/src/main/scala/ldbc/connector/ConnectionImpl.scala

@@ -33,7 +33,7 @@ private[ldbc] case class ConnectionImpl[F[_]: Temporal: Tracer: Console: Exchang
   readOnly:         Ref[F, Boolean],
   isAutoCommit:     Ref[F, Boolean],
   connectionClosed: Ref[F, Boolean],
-  databaseTerm:     Option[DatabaseMetaData.DatabaseTerm] = None
+  databaseTerm:     Option[DatabaseMetaData.DatabaseTerm] = Some(DatabaseMetaData.DatabaseTerm.CATALOG)
 )(using ev: MonadError[F, Throwable])
   extends LdbcConnection[F]:
 
@@ -115,8 +115,12 @@ private[ldbc] case class ConnectionImpl[F[_]: Temporal: Tracer: Console: Exchang
     else ev.unit
 
   override def getCatalog(): F[String] =
-    if databaseTerm.contains(DatabaseMetaData.DatabaseTerm.CATALOG) then getSchema()
-    else ev.pure("")
+    if databaseTerm.contains(DatabaseMetaData.DatabaseTerm.CATALOG) then
+      for
+        statement <- createStatement()
+        result    <- statement.executeQuery("SELECT DATABASE()")
+      yield Option(result.getString(1)).getOrElse("")
+    else ev.pure(null)
 
   override def setTransactionIsolation(level: Int): F[Unit] =
     level match
@@ -484,10 +488,12 @@ private[ldbc] case class ConnectionImpl[F[_]: Temporal: Tracer: Console: Exchang
   override def setSchema(schema: String): F[Unit] = protocol.resetSequenceId *> protocol.comInitDB(schema)
 
   override def getSchema(): F[String] =
-    for
-      statement <- createStatement()
-      result    <- statement.executeQuery("SELECT DATABASE()")
-    yield Option(result.getString(1)).getOrElse("")
+    if databaseTerm.contains(DatabaseMetaData.DatabaseTerm.SCHEMA) then
+      for
+        statement <- createStatement()
+        result    <- statement.executeQuery("SELECT DATABASE()")
+      yield Option(result.getString(1)).getOrElse("")
+    else ev.pure(null)
 
   override def getStatistics: F[StatisticsPacket] = protocol.resetSequenceId *> protocol.comStatistics()
 

module/ldbc-connector/shared/src/main/scala/ldbc/connector/data/MysqlType.scala

@@ -610,6 +610,15 @@ enum MysqlType(
    */
   case GEOMETRY extends MysqlType("GEOMETRY", Types.BINARY, 0, MysqlTypeVariables.IS_NOT_DECIMAL, 65535L, "")
 
+  /**
+   * VECTOR[(M)]
+   * A VECTOR column with a maximum length of 65,532 (16383 x 4) bytes. An optional length M can be given for this type to indicate the maximum number of
+   * entries in a VECTOR. M cannot exceed 16383. Each entry is a 4 Byte (single-precision) floating-point value.
+   *
+   * Protocol: FIELD_TYPE_VECTOR = 242
+   */
+  case VECTOR extends MysqlType("VECTOR", Types.LONGVARBINARY, 0, MysqlTypeVariables.IS_NOT_DECIMAL, 65532L, "[(M)]")
+
   /**
    * Fall-back type for those MySQL data types which c/J can't recognize.
    * Handled the same as BLOB.
@@ -689,6 +698,7 @@ object MysqlType:
       case name if name.contains("BLOB")                                                     => MysqlType.BLOB
       case name if name.contains("TEXT")                                                     => MysqlType.TEXT
       case name if name.contains("GEOM") | name.contains("POINT") | name.contains("POLYGON") => MysqlType.GEOMETRY
+      case name if name.contains("VECTOR")                                                   => MysqlType.VECTOR
       case _                                                                                 => MysqlType.UNKNOWN
 
 /**

module/ldbc-connector/shared/src/main/scala/ldbc/connector/util/StringHelper.scala

@@ -71,3 +71,14 @@ object StringHelper:
   def getUniqueSavepointId: String =
     val uuid = UUID.randomUUID().toString
     uuid.replaceAll("-", "_")
+
+  /**
+   * Does the string contain wildcard symbols ('%' or '_'). Used in DatabaseMetaData.
+   *
+   * @param src
+   *   string
+   * @return
+   *   true if src contains wildcard symbols
+   */
+  def hasWildcards(src: String): Boolean =
+    indexOfIgnoreCase(0, src, "%") != -1 || indexOfIgnoreCase(0, src, "_") != -1

module/ldbc-sql/src/main/scala/ldbc/sql/DatabaseMetaData.scala

@@ -1064,7 +1064,7 @@ trait DatabaseMetaData[F[_]]:
    * Only procedure descriptions matching the schema and
    * procedure name criteria are returned.  They are ordered by
    * <code>PROCEDURE_CAT</code>, <code>PROCEDURE_SCHEM</code>,
-   * <code>PROCEDURE_NAME</code> and <code>SPECIFIC_ NAME</code>.
+   * <code>PROCEDURE_NAME</code> and <code>SPECIFIC_NAME</code>.
    *
    * <P>Each procedure description has the following columns:
    *  <OL>