db_holder

package

v1.2.3 Latest Latest Go to latest Published: Sep 10, 2024 License: Apache-2.0 Imports: 12 Imported by: 0

Details

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

Repository

github.com/matrixorigin/matrixone

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func CloseDBConn()
func GetLabelSelector() map[string]string
func GetOrInitDBConn(forceNewConn bool, randomCN bool) (*sql.DB, error)
func GetSQLWriterDBAddressFunc() func(context.Context, bool) (string, error)
func IsRecordExisted(ctx context.Context, record []string, tbl *table.Table, ...) (bool, error)
func SetDBConn(conn *sql.DB)
func SetLabelSelector(labels map[string]string)
func SetSQLWriterDBAddressFunc(f func(context.Context, bool) (string, error))
func SetSQLWriterDBUser(userName string, password string)
func WriteRowRecords(records [][]string, tbl *table.Table, timeout time.Duration) (int, error)
type CSVWriter
- func NewCSVWriter(ctx context.Context) *CSVWriter
type DBConnProvider
type DBUser
- func GetSQLWriterDBUser() (*DBUser, error)

Constants ¶

View Source

const DBConnRetryThreshold = 8

View Source

const DBRefreshTime = time.Hour

View Source

const MOLoggerUser = "mo_logger"

View Source

const MaxConnectionNumber = 1

Variables ¶

View Source

var (
	DBConnErrCount atomic.Uint32
)

sqlWriterDBUser holds the db user for logger

Functions ¶

func CloseDBConn ¶ added in v1.0.1

func CloseDBConn()

func GetLabelSelector ¶ added in v1.1.2

func GetLabelSelector() map[string]string

GetLabelSelector Tips: more details in route.RouteForSuperTenant function. It mainly depends on S1. Tips: gLabels better contain {"account":"sys"}. - Because clusterservice.Selector using clusterservice.globbing do regex-match in route.RouteForSuperTenant - If you use labels{"account":"sys", "role":"ob"}, the Selector can match those pods, which have labels{"account":"*", "role":"ob"}

func GetOrInitDBConn ¶ added in v1.0.1

func GetOrInitDBConn(forceNewConn bool, randomCN bool) (*sql.DB, error)

func GetSQLWriterDBAddressFunc ¶

func GetSQLWriterDBAddressFunc() func(context.Context, bool) (string, error)

func IsRecordExisted ¶ added in v1.0.0

func IsRecordExisted(ctx context.Context, record []string, tbl *table.Table, getDBConn DBConnProvider) (bool, error)

func SetDBConn ¶

func SetDBConn(conn *sql.DB)

func SetLabelSelector ¶ added in v1.1.2

func SetLabelSelector(labels map[string]string)

func SetSQLWriterDBAddressFunc ¶

func SetSQLWriterDBAddressFunc(f func(context.Context, bool) (string, error))

func SetSQLWriterDBUser ¶

func SetSQLWriterDBUser(userName string, password string)

func WriteRowRecords ¶

func WriteRowRecords(records [][]string, tbl *table.Table, timeout time.Duration) (int, error)

Types ¶

type CSVWriter ¶ added in v1.0.0

type CSVWriter struct {
	// contains filtered or unexported fields
}

func NewCSVWriter ¶ added in v1.0.0

func NewCSVWriter(ctx context.Context) *CSVWriter

func (*CSVWriter) GetContent ¶ added in v1.0.0

func (w *CSVWriter) GetContent() string

func (*CSVWriter) Release ¶ added in v1.0.0

func (w *CSVWriter) Release()

func (*CSVWriter) WriteStrings ¶ added in v1.0.0

func (w *CSVWriter) WriteStrings(record []string) error

type DBConnProvider ¶ added in v1.0.0

type DBConnProvider func(forceNewConn bool, randomCN bool) (*sql.DB, error)

type DBUser ¶

type DBUser struct {
	UserName string
	Password string
}

func GetSQLWriterDBUser ¶

func GetSQLWriterDBUser() (*DBUser, error)

Source Files ¶

View all Source files

db_holder.go

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