hive

README

hive

GORM hive driver

install hive

docker run -d -p 10000:10000 -p 10002:10002 --env SERVICE_NAME=hiveserver2 --name hive4.0.0 apache/hive:4.0.0

features

• Exec
• Find
• auto Migration
• sql args
• sql date type Array Map Struct

Documentation

Index

• Constants
• Variables
• func New(config Config) gorm.Dialector
• func Open(dsn string) gorm.Dialector
• type Config
• type DSNConfig
  • func ParseDSN(dsn string) (*DSNConfig, error)
  • func (c *DSNConfig) Complete() *DSNConfig
  • func (c *DSNConfig) FormatDSN() string
• type Dialector
  • func (dialector *Dialector) BindVarTo(writer clause.Writer, stmt *gorm.Statement, v interface{})
  • func (dialector *Dialector) DataTypeOf(field *schema.Field) string
  • func (dialector *Dialector) DefaultValueOf(field *schema.Field) clause.Expression
  • func (dialector *Dialector) Explain(sql string, vars ...interface{}) string
  • func (dialector *Dialector) Initialize(db *gorm.DB) (err error)
  • func (dialector *Dialector) Migrator(db *gorm.DB) gorm.Migrator
  • func (dialector *Dialector) Name() string
  • func (dialector *Dialector) QuoteTo(writer clause.Writer, str string)
  • func (dialector *Dialector) RegisterCallbacks(db *gorm.DB, config *callbacks.Config)
• type MapSerializer
  • func (MapSerializer) Scan(ctx context.Context, field *schema.Field, dst reflect.Value, ...) (err error)
  • func (MapSerializer) Value(ctx context.Context, field *schema.Field, dst reflect.Value, ...) (interface{}, error)
• type Migrator
  • func (m Migrator) CurrentDatabase() (name string)
  • func (m Migrator) HasTable(value interface{}) bool

Constants

const (
	DriverName = "hive"
)

Variables

var (
	// CreateClauses create clauses
	CreateClauses = []string{"INSERT", "VALUES", "ON CONFLICT"}
	// QueryClauses query clauses
	QueryClauses = []string{"SELECT", "FROM", "WHERE", "GROUP BY", "ORDER BY", "LIMIT", "FOR"}
	// UpdateClauses update clauses
	UpdateClauses = []string{"UPDATE", "SET", "WHERE"}
	// DeleteClauses delete clauses
	DeleteClauses = []string{"DELETE", "FROM", "WHERE"}
)

Functions

func New

func New(config Config) gorm.Dialector

func Open

func Open(dsn string) gorm.Dialector

Types

type Config

type Config struct {
	DriverName    string
	ServerVersion string
	DSN           string
	DSNConfig     *DSNConfig
	Conn          gorm.ConnPool

	DefaultStringSize uint
}

type DSNConfig

type DSNConfig gohive.Config

func ParseDSN

func ParseDSN(dsn string) (*DSNConfig, error)

func (*DSNConfig) Complete

func (c *DSNConfig) Complete() *DSNConfig

func (*DSNConfig) FormatDSN

func (c *DSNConfig) FormatDSN() string

type Dialector

type Dialector struct {
	*Config
	// contains filtered or unexported fields
}

func (*Dialector) BindVarTo

func (dialector *Dialector) BindVarTo(writer clause.Writer, stmt *gorm.Statement, v interface{})

func (*Dialector) DataTypeOf

func (dialector *Dialector) DataTypeOf(field *schema.Field) string

func (*Dialector) DefaultValueOf

func (dialector *Dialector) DefaultValueOf(field *schema.Field) clause.Expression

func (*Dialector) Explain

func (dialector *Dialector) Explain(sql string, vars ...interface{}) string

func (*Dialector) Initialize

func (dialector *Dialector) Initialize(db *gorm.DB) (err error)

func (*Dialector) Migrator

func (dialector *Dialector) Migrator(db *gorm.DB) gorm.Migrator

func (*Dialector) Name

func (dialector *Dialector) Name() string

func (*Dialector) QuoteTo

func (dialector *Dialector) QuoteTo(writer clause.Writer, str string)

func (*Dialector) RegisterCallbacks

func (dialector *Dialector) RegisterCallbacks(db *gorm.DB, config *callbacks.Config)

type MapSerializer

type MapSerializer struct{}

MapSerializer map serializer

func (MapSerializer) Scan

func (MapSerializer) Scan(ctx context.Context, field *schema.Field, dst reflect.Value, dbValue interface{}) (err error)

Scan implements serializer interface

func (MapSerializer) Value

func (MapSerializer) Value(ctx context.Context, field *schema.Field, dst reflect.Value, fieldValue interface{}) (interface{}, error)

Value implements serializer interface

type Migrator

type Migrator struct {
	migrator.Migrator
	*Dialector
}

func (Migrator) CurrentDatabase

func (m Migrator) CurrentDatabase() (name string)

func (Migrator) HasTable

func (m Migrator) HasTable(value interface{}) bool