service

Documentation

Index

• Constants
• func AddCloudBeaverInstance(client *gqlClient.Client, sqleInst *sqleModel.Instance) error
• func GenerateCloudBeaverDriverID(sqleInst *sqleModel.Instance) (string, error)
• func GenerateCloudBeaverUserName(name string) string
• func GetCurrentCloudBeaverUserID(ctx echo.Context) (string, bool, error)
• func GetGQLClient(username, password string) (*gqlClient.Client, error)
• func GetGQLClientWithRootUser() (*gqlClient.Client, error)
• func GetGqlServerURI() string
• func GetSQLEGQLClientWithCurrentUser(ctx echo.Context) (*gqlClient.Client, error)
• func GetSQLEGqlServerURI() string
• func InitSQLQueryConfig(sqlePort int, sqleEnableHttps bool, c config.SQLQueryConfig)
• func IsCloudBeaverConfigured() bool
• func IsReserved(name string) bool
• func Login(user, pwd string) (cookie []*http.Cookie, err error)
• func LoginToCBServer(user, pwd string) (cookie []*http.Cookie, err error)
• func RestoreFromCloudBeaverUserName(name string) string
• func SyncCurrentUser(cloudBeaverUser string) error
• func SyncInstance(sqleInstances map[uint]*sqleModel.Instance) error
• func SyncUserBindInstance(cbUserID string) error
• func SyncVisibleInstance(cbUserCache *sqleModel.CloudBeaverUserCache, sqleUser *sqleModel.User, ...) error
• func UpdateCloudBeaverInstance(client *gqlClient.Client, cbInstID string, sqleInst *sqleModel.Instance) error
• type AuditResult
  • func AuditSQL(sql string, connectionID string) (auditSuccess bool, result *AuditResult, err error)
• type SQLQueryConfig
  • func GetSQLQueryConfig() *SQLQueryConfig

Constants

const (
	CbRootUri  = "/sql_query"
	CbGqlApi   = "/api/gql"
	CBUserRole = "user"
)

const (
	GetUserConnectionsQuery = `` /* 231-byte string literal not displayed */

	SetUserConnectionsQuery = `` /* 169-byte string literal not displayed */

)

const (
	IsUserExistQuery = `` /* 143-byte string literal not displayed */

	UpdatePasswordQuery = `` /* 172-byte string literal not displayed */

	CreateUserQuery = `` /* 156-byte string literal not displayed */

	GrantUserRoleQuery = `
query grantUserRole($userId: ID!, $roleId: ID!) {
  grantUserRole(userId: $userId, roleId: $roleId)
}`
)

const CBNamePrefix = "sqle-"

const (
	CreateConnectionQuery = `` /* 240-byte string literal not displayed */

)

const (
	GetActiveUserQuery = `
	query getActiveUser {
  		user: activeUser {
    		userId
  		}
	}
`
)

const LoginQuery = `` /* 189-byte string literal not displayed */

const (
	UpdateConnectionQuery = `` /* 240-byte string literal not displayed */

)

Functions

func AddCloudBeaverInstance

func AddCloudBeaverInstance(client *gqlClient.Client, sqleInst *sqleModel.Instance) error

AddCloudBeaverInstance 添加实例后会同步缓存

func GenerateCloudBeaverDriverID

func GenerateCloudBeaverDriverID(sqleInst *sqleModel.Instance) (string, error)

func GenerateCloudBeaverUserName

func GenerateCloudBeaverUserName(name string) string

func GetCurrentCloudBeaverUserID

func GetCurrentCloudBeaverUserID(ctx echo.Context) (string, bool, error)

func GetGQLClient

func GetGQLClient(username, password string) (*gqlClient.Client, error)

func GetGQLClientWithRootUser

func GetGQLClientWithRootUser() (*gqlClient.Client, error)

func GetGqlServerURI

func GetGqlServerURI() string

func GetSQLEGQLClientWithCurrentUser

func GetSQLEGQLClientWithCurrentUser(ctx echo.Context) (*gqlClient.Client, error)

func GetSQLEGqlServerURI

func GetSQLEGqlServerURI() string

func InitSQLQueryConfig

func InitSQLQueryConfig(sqlePort int, sqleEnableHttps bool, c config.SQLQueryConfig)

func IsCloudBeaverConfigured

func IsCloudBeaverConfigured() bool

func IsReserved

func IsReserved(name string) bool

IsReserved 会检查用户名是否为无法使用的名称, 比如admin和user是角色名, 按照CloudBeaver的要求角色名无法作为用户名

func Login

func Login(user, pwd string) (cookie []*http.Cookie, err error)

func LoginToCBServer

func LoginToCBServer(user, pwd string) (cookie []*http.Cookie, err error)

LoginToCBServer 的登录请求会直接被转发, 不会被中间件拦截处理

func RestoreFromCloudBeaverUserName

func RestoreFromCloudBeaverUserName(name string) string

func SyncCurrentUser

func SyncCurrentUser(cloudBeaverUser string) error

func SyncInstance

func SyncInstance(sqleInstances map[uint]*sqleModel.Instance) error

func SyncUserBindInstance

func SyncUserBindInstance(cbUserID string) error

func SyncVisibleInstance

func SyncVisibleInstance(cbUserCache *sqleModel.CloudBeaverUserCache, sqleUser *sqleModel.User, sqleInstances map[uint]*sqleModel.Instance) error

func UpdateCloudBeaverInstance

func UpdateCloudBeaverInstance(client *gqlClient.Client, cbInstID string, sqleInst *sqleModel.Instance) error

UpdateCloudBeaverInstance 更新完毕后会同步缓存

Types

type AuditResult

type AuditResult struct {
	Result     string
	LimitLevel string
	AuditLevel string
}

func AuditSQL

func AuditSQL(sql string, connectionID string) (auditSuccess bool, result *AuditResult, err error)

type SQLQueryConfig

type SQLQueryConfig struct {
	config.SQLQueryConfig
	SqlePort        int
	SqleEnableHttps bool
}

func GetSQLQueryConfig

func GetSQLQueryConfig() *SQLQueryConfig