sql

package

v0.0.70 Latest Latest Go to latest Published: Dec 22, 2025 License: Apache-2.0 Imports: 3 Imported by: 1

Details

This section is empty.

View Source

var AlterPublicationSetTable = `ALTER PUBLICATION %s SET TABLE %s;`

View Source

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

View Source

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

View Source

var CreatePublicationForTables = `CREATE PUBLICATION %s FOR TABLE %s;`

View Source

var DropPublication = `DROP PUBLICATION %s;`

View Source

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

View Source

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

View Source

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

View Source

var QueryPublication = `SELECT puballtables FROM pg_publication WHERE pubname = $1;`

View Source

var QueryPublicationTables = `SELECT schemaname, tablename FROM pg_publication_tables WHERE pubname = $1;`

View Source

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

View Source

var ServerVersionNum = `SHOW server_version_num;`

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 struct {
	Namespace string
	Table     string
	Count     int
	Keys      []string
	Fields    []*pb.Field
	PGVersion int64
}