cql

package

v1.0.2 Latest Latest Go to latest Published: Nov 3, 2022 License: MIT Imports: 8 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/capillariesio/capillaries

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func IsDbConnError(err error) bool
func NewSession(envConfig *env.EnvConfig, keyspace string) (*gocql.Session, error)
func WrapDbErrorWithQuery(msg string, query string, dbErr error) error
type IfNotExistsType
type QueryBuilder
type QuotePolicyType

Constants ¶

View Source

const ErrorPrefixDb string = "dberror:"

View Source

const RunIdForEmptyRun = -1

Insert - build INSERT query

Variables ¶

This section is empty.

Functions ¶

func IsDbConnError ¶

func IsDbConnError(err error) bool

func NewSession ¶

func NewSession(envConfig *env.EnvConfig, keyspace string) (*gocql.Session, error)

func WrapDbErrorWithQuery ¶

func WrapDbErrorWithQuery(msg string, query string, dbErr error) error

Types ¶

type IfNotExistsType ¶

type IfNotExistsType int

const (
	IgnoreIfExists IfNotExistsType = 1
	ThrowIfExists  IfNotExistsType = 0
)

type QueryBuilder ¶

type QueryBuilder struct {
	ColumnDefs           queryBuilderColumnDefs
	PartitionKeyColumns  []string
	ClusteringKeyColumns []string
	ColumnData           queryBuilderColumnData
	Conditions           queryBuilderConditions
	IfConditions         queryBuilderConditions
	SelectLimit          int
	FormattedKeyspace    string
	OrderByColumns       []string
}

QueryBuilder - very simple cql query builder that does not require db connection

func (*QueryBuilder) ClusteringKey ¶

func (qb *QueryBuilder) ClusteringKey(column ...string) *QueryBuilder

func (*QueryBuilder) ColumnDef ¶

func (qb *QueryBuilder) ColumnDef(column string, fieldType sc.TableFieldType) *QueryBuilder

func (*QueryBuilder) Cond ¶

func (qb *QueryBuilder) Cond(column string, op string, value interface{}) *QueryBuilder

Cond - add condition for SELECT, UPDATE or DELETE

func (*QueryBuilder) CondIn ¶

func (qb *QueryBuilder) CondIn(column string, values []interface{}) *QueryBuilder

CondIn - add IN condition for SELECT, UPDATE or DELETE

func (*QueryBuilder) CondInInt ¶

func (qb *QueryBuilder) CondInInt(column string, values []int64) *QueryBuilder

func (*QueryBuilder) CondInInt16 ¶

func (qb *QueryBuilder) CondInInt16(column string, values []int16) *QueryBuilder

func (*QueryBuilder) CondInString ¶

func (qb *QueryBuilder) CondInString(column string, values []string) *QueryBuilder

func (*QueryBuilder) Create ¶

func (qb *QueryBuilder) Create(tableName string, ifNotExists IfNotExistsType) string

func (*QueryBuilder) CreateRun ¶

func (qb *QueryBuilder) CreateRun(tableName string, runId int16, ifNotExists IfNotExistsType) string

func (*QueryBuilder) Delete ¶

func (qb *QueryBuilder) Delete(tableName string) string

Delete - build DELETE query

func (*QueryBuilder) DeleteRun ¶

func (qb *QueryBuilder) DeleteRun(tableName string, runId int16) string

func (*QueryBuilder) Drop ¶

func (qb *QueryBuilder) Drop(tableName string) string

func (*QueryBuilder) DropKeyspace ¶

func (qb *QueryBuilder) DropKeyspace() string

func (*QueryBuilder) DropRun ¶

func (qb *QueryBuilder) DropRun(tableName string, runId int16) string

func (*QueryBuilder) If ¶

func (qb *QueryBuilder) If(column string, op string, value interface{}) *QueryBuilder

func (*QueryBuilder) Insert ¶

func (qb *QueryBuilder) Insert(tableName string, ifNotExists IfNotExistsType) string

func (*QueryBuilder) InsertRun ¶

func (qb *QueryBuilder) InsertRun(tableName string, runId int16, ifNotExists IfNotExistsType) string

func (*QueryBuilder) Keyspace ¶

func (qb *QueryBuilder) Keyspace(keyspace string) *QueryBuilder

Keyspace - specify keyspace (optional)

func (*QueryBuilder) Limit ¶

func (qb *QueryBuilder) Limit(limit int) *QueryBuilder

func (*QueryBuilder) OrderBy ¶

func (qb *QueryBuilder) OrderBy(columns ...string) *QueryBuilder

func (*QueryBuilder) PartitionKey ¶

func (qb *QueryBuilder) PartitionKey(column ...string) *QueryBuilder

func (*QueryBuilder) Select ¶

func (qb *QueryBuilder) Select(tableName string, columns []string) string

Select - build SELECT query

func (*QueryBuilder) SelectRun ¶

func (qb *QueryBuilder) SelectRun(tableName string, runId int16, columns []string) string

func (*QueryBuilder) Update ¶

func (qb *QueryBuilder) Update(tableName string) string

Update - build UPDATE query

func (*QueryBuilder) UpdateRun ¶

func (qb *QueryBuilder) UpdateRun(tableName string, runId int16) string

func (*QueryBuilder) Write ¶

func (qb *QueryBuilder) Write(column string, value interface{}) *QueryBuilder

Write - add a column for INSERT or UPDATE

func (*QueryBuilder) WriteForceUnquote ¶

func (qb *QueryBuilder) WriteForceUnquote(column string, value interface{}) *QueryBuilder

WriteForceUnquote - add a column for INSERT or UPDATE

type QuotePolicyType ¶

type QuotePolicyType int

const (
	LeaveQuoteAsIs QuotePolicyType = iota
	ForceUnquote
)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL