type golang.org/x/pkgsite/internal/database.DB

90 uses

	golang.org/x/pkgsite/internal/database (current package)
		copy.go#L32: func (db *DB) CopyUpsert(ctx context.Context, table string, columns []string, src pgx.CopyFromSource, conflictColumns []string, dropColumn string) (err error) {
		copy.go#L76: func (db *DB) WithPGXConn(f func(conn *pgx.Conn) error) error {
		database.go#L32: type DB struct {
		database.go#L43: func Open(driverName, dbinfo, instanceID string) (_ *DB, err error) {
		database.go#L61: func New(db *sql.DB, instanceID string) *DB {
		database.go#L62: 	return &DB{db: db, instanceID: instanceID}
		database.go#L65: func (db *DB) Ping() error {
		database.go#L69: func (db *DB) InTransaction() bool {
		database.go#L73: func (db *DB) IsRetryable() bool {
		database.go#L84: func (db *DB) Close() error {
		database.go#L89: func (db *DB) Exec(ctx context.Context, query string, args ...interface{}) (_ int64, err error) {
		database.go#L103: func (db *DB) execResult(ctx context.Context, query string, args ...interface{}) (res sql.Result, err error) {
		database.go#L111: func (db *DB) Query(ctx context.Context, query string, args ...interface{}) (_ *sql.Rows, err error) {
		database.go#L120: func (db *DB) QueryRow(ctx context.Context, query string, args ...interface{}) *sql.Row {
		database.go#L136: func (db *DB) Prepare(ctx context.Context, query string) (*sql.Stmt, error) {
		database.go#L145: func (db *DB) RunQuery(ctx context.Context, query string, f func(*sql.Rows) error, params ...interface{}) error {
		database.go#L173: func (db *DB) Transact(ctx context.Context, iso sql.IsolationLevel, txFunc func(*DB) error) (err error) {
		database.go#L193: func (db *DB) transactWithRetry(ctx context.Context, opts *sql.TxOptions, txFunc func(*DB) error) (err error) {
		database.go#L237: func (db *DB) transact(ctx context.Context, opts *sql.TxOptions, txFunc func(*DB) error) (err error) {
		database.go#L276: func (db *DB) MaxRetries() int {
		database.go#L290: func (db *DB) BulkInsert(ctx context.Context, table string, columns []string, values []interface{}, conflictAction string) (err error) {
		database.go#L301: func (db *DB) BulkInsertReturning(ctx context.Context, table string, columns []string, values []interface{}, conflictAction string, returningColumns []string, scanFunc func(*sql.Rows) error) (err error) {
		database.go#L315: func (db *DB) BulkUpsert(ctx context.Context, table string, columns []string, values []interface{}, conflictColumns []string) error {
		database.go#L321: func (db *DB) BulkUpsertReturning(ctx context.Context, table string, columns []string, values []interface{}, conflictColumns, returningColumns []string, scanFunc func(*sql.Rows) error) error {
		database.go#L326: func (db *DB) bulkInsert(ctx context.Context, table string, columns, returningColumns []string, values []interface{}, conflictAction string, scanFunc func(*sql.Rows) error) (err error) {
		database.go#L447: func (db *DB) BulkUpdate(ctx context.Context, table string, columns, types []string, values [][]interface{}) (err error) {
		logging.go#L123: func (db *DB) logTransaction(ctx context.Context) func(*error) {
		reflect.go#L131: func (db *DB) CollectStructs(ctx context.Context, pslice interface{}, query string, args ...interface{}) error {

	golang.org/x/pkgsite/internal/postgres
		delete.go#L20: 	return db.db.Transact(ctx, sql.LevelDefault, func(tx *database.DB) error {
		excluded.go#L59: func getExcludedPrefixes(ctx context.Context, db *database.DB) ([]string, error) {
		insert_module.go#L85: 	err = db.db.Transact(ctx, sql.LevelRepeatableRead, func(tx *database.DB) error {
		insert_module.go#L94: 	err = db.db.Transact(ctx, sql.LevelRepeatableRead, func(tx *database.DB) error {
		insert_module.go#L189: func isAlternativeModulePath(ctx context.Context, db *database.DB, modulePath string) (_ bool, err error) {
		insert_module.go#L212: func insertModule(ctx context.Context, db *database.DB, m *internal.Module) (_ int, err error) {
		insert_module.go#L261: func insertLicenses(ctx context.Context, db *database.DB, m *internal.Module, moduleID int) (err error) {
		insert_module.go#L299: func insertImportsUnique(ctx context.Context, tx *database.DB, m *internal.Module) (err error) {
		insert_module.go#L329: func (pdb *DB) insertUnits(ctx context.Context, db *database.DB, m *internal.Module, moduleID int, pathToID map[string]int) (err error) {
		insert_module.go#L433: func insertPaths(ctx context.Context, tx *database.DB, m *internal.Module) (pathToID map[string]int, err error) {
		insert_module.go#L450: func insertUnits(ctx context.Context, db *database.DB, unitValues []interface{}) (pathIDToUnitID map[int]int, err error) {
		insert_module.go#L497: func insertDocs(ctx context.Context, db *database.DB,
		insert_module.go#L529: func getDocIDsForPath(ctx context.Context, db *database.DB,
		insert_module.go#L569: func insertImports(ctx context.Context, db *database.DB,
		insert_module.go#L590: func insertReadmes(ctx context.Context, db *database.DB,
		insert_module.go#L622: 	return db.db.Transact(ctx, sql.LevelRepeatableRead, func(tx *database.DB) error {
		insert_module.go#L730: func lock(ctx context.Context, tx *database.DB, modulePath string) (err error) {
		insert_module.go#L848: 	return db.db.Transact(ctx, sql.LevelDefault, func(tx *database.DB) error {
		insert_symbol_history.go#L19: func upsertSymbolHistory(ctx context.Context, ddb *database.DB,
		package_symbol.go#L22: func getPackageSymbols(ctx context.Context, ddb *database.DB, packagePath, modulePath string,
		package_symbol.go#L103: func upsertSearchDocumentSymbols(ctx context.Context, ddb *database.DB,
		path.go#L79: func upsertPath(ctx context.Context, tx *database.DB, path string) (id int, err error) {
		path.go#L113: func upsertPaths(ctx context.Context, db *database.DB, paths []string) (pathToID map[string]int, err error) {
		path.go#L155: func GetPathID(ctx context.Context, ddb *database.DB, path string) (id int, err error) {
		postgres.go#L21: 	db                 *database.DB
		postgres.go#L28: func New(db *database.DB) *DB {
		postgres.go#L35: func NewBypassingLicenseCheck(db *database.DB) *DB {
		postgres.go#L42: func newdb(db *database.DB, bypass bool) *DB {
		postgres.go#L71: func (db *DB) Underlying() *database.DB {
		postgres.go#L117: func collectStrings(ctx context.Context, db *database.DB, query string, args ...interface{}) (ss []string, err error) {
		search.go#L629: func upsertSearchDocuments(ctx context.Context, ddb *database.DB, mod *internal.Module) (err error) {
		search.go#L672: func UpsertSearchDocument(ctx context.Context, ddb *database.DB, args UpsertSearchDocumentArgs) (err error) {
		search.go#L756: 	err = db.db.Transact(ctx, sql.LevelDefault, func(tx *database.DB) error {
		search.go#L829: func insertImportedByCounts(ctx context.Context, db *database.DB, counts map[string]int) (err error) {
		search.go#L849: func compareImportedByCounts(ctx context.Context, db *database.DB) (err error) {
		search.go#L905: func updateImportedByCounts(ctx context.Context, db *database.DB) (int64, error) {
		search.go#L1021: 	return db.db.Transact(ctx, sql.LevelDefault, func(tx *database.DB) error {
		symbol.go#L19: func insertSymbols(ctx context.Context, db *database.DB, modulePath, version string,
		symbol.go#L56: func upsertDocumentationSymbols(ctx context.Context, db *database.DB,
		symbol.go#L165: func upsertPackageSymbolsReturningIDs(ctx context.Context, db *database.DB,
		symbol.go#L301: func upsertSymbolNamesReturningIDs(ctx context.Context, db *database.DB,
		symbol.go#L353: func getUnitSymbols(ctx context.Context, db *database.DB, unitID int) (_ map[internal.BuildContext][]*internal.Symbol, err error) {
		symbol_history.go#L41: func GetSymbolHistoryFromTable(ctx context.Context, ddb *database.DB,
		symbol_history.go#L79: func GetSymbolHistoryWithPackageSymbols(ctx context.Context, ddb *database.DB,
		symbol_history.go#L94: func GetSymbolHistoryForBuildContext(ctx context.Context, ddb *database.DB, pathID int, modulePath string,
		test_helper.go#L110: 	if err := db.db.Transact(ctx, sql.LevelDefault, func(tx *database.DB) error {
		unit.go#L331: func getPackagesInUnit(ctx context.Context, db *database.DB, fullPath, modulePath, resolvedVersion string, moduleID int, bypassLicenseCheck bool) (_ []*internal.PackageMeta, err error) {
		unit.go#L632: func getModuleReadme(ctx context.Context, db *database.DB, modulePath, resolvedVersion string) (_ *internal.Readme, err error) {
		version.go#L368: func getLatestGoodVersion(ctx context.Context, tx *database.DB, modulePath string, lmv *internal.LatestModuleVersions) (_ string, err error) {
		version.go#L413: func getLatestModuleVersions(ctx context.Context, db *database.DB, modulePath string) (_ *internal.LatestModuleVersions, id int, err error) {
		version.go#L464: 	err = db.db.Transact(ctx, sql.LevelRepeatableRead, func(tx *database.DB) error {
		version.go#L514: 	return db.db.Transact(ctx, sql.LevelRepeatableRead, func(tx *database.DB) error {
		version.go#L533: func upsertLatestModuleVersions(ctx context.Context, tx *database.DB, modulePath string, id int, lmv *internal.LatestModuleVersions, status int) (err error) {
		version.go#L585: func updateLatestGoodVersion(ctx context.Context, tx *database.DB, modulePath, version string) (err error) {
		versionstate.go#L40: 	return db.db.Transact(ctx, sql.LevelDefault, func(tx *database.DB) error {
		versionstate.go#L72: 	return db.db.Transact(ctx, sql.LevelDefault, func(tx *database.DB) error {
		versionstate.go#L87: func upsertModuleVersionState(ctx context.Context, db *database.DB, numPackages *int, mvs *ModuleVersionStateForUpsert) (err error) {
		versionstate.go#L145: func updateModulesStatus(ctx context.Context, db *database.DB, modulePath, resolvedVersion string, status int) (err error) {
		versionstate.go#L177: func upsertPackageVersionStates(ctx context.Context, db *database.DB, packageVersionStates []*internal.PackageVersionState) (err error) {