sql

Documentation

Index

• Variables
• func DeleteQuery(namespace, table string, fields []*pb.Field) string
• func InsertQuery(opt InsertOption) string
• func UpdateQuery(namespace, table string, sets, keys []*pb.Field) string
• type InsertOption

Variables

var CreateLogicalSlot = `SELECT pg_create_logical_replication_slot($1, $2);`

var CreatePublication = `CREATE PUBLICATION %s FOR ALL TABLES;`

var InstallExtension = `CREATE EXTENSION IF NOT EXISTS pgcapture;`

var QueryAttrTypeOID = `` /* 360-byte string literal not displayed */

var QueryIdentityKeys = `` /* 875-byte string literal not displayed */

var QueryReplicationSlot = `SELECT confirmed_flush_lsn FROM pg_replication_slots WHERE slot_name = $1;`

var ServerVersionNum = `SHOW server_version_num;`

Functions

func DeleteQuery

func DeleteQuery(namespace, table string, fields []*pb.Field) string

func InsertQuery

func InsertQuery(opt InsertOption) string

func UpdateQuery

func UpdateQuery(namespace, table string, sets, keys []*pb.Field) string

Types

type InsertOption

type InsertOption struct {
	Namespace string
	Table     string
	Count     int
	Keys      []string
	Fields    []*pb.Field
	PGVersion int64
}