Merge pull request #508 from datbeohbbh/datbeohbbh/xorm

Embedding `internal/xsql` package

Author: asmyasnikov

CHANGELOG.md

@@ -1,3 +1,7 @@
+* Implemented `driver.RowsColumnTypeDatabaseTypeName` interface in `internal/xsql.rows` struct
+* Extended `internal/xsql.conn` struct with methods for getting `YDB` metadata
+* Added `scheme.Client` to `internal/xsql.connection` interface
+* Added `helpers` package with method for checking existence of table, refactored `sugar.IsTableExists()`
 * Added checks for nil option to all opts range loops
 * Moved content of package `internal/ctxlabels` into `internal/xcontext`
 * Implemented `GRPCStatus` method in `internal/xerrors/transportError`

internal/scheme/helpers/table_exists.go

@@ -0,0 +1,30 @@
+package helpers
+
+import (
+	"context"
+	"fmt"
+	"path"
+
+	"github.com/ydb-platform/ydb-go-sdk/v3/scheme"
+)
+
+func IsTableExists(ctx context.Context, c scheme.Client, absTablePath string) (exists bool, _ error) {
+	directory, tableName := path.Split(absTablePath)
+	d, err := c.ListDirectory(ctx, directory)
+	if err != nil {
+		return false, err
+	}
+	for _, e := range d.Children {
+		if e.Name != tableName {
+			continue
+		}
+		if e.Type != scheme.EntryTable {
+			return false, fmt.Errorf(
+				"entry '%s' in path '%s' is not a table: %s",
+				tableName, directory, e.Type.String(),
+			)
+		}
+		return true, nil
+	}
+	return false, nil
+}