Function GetReferenceIdToIdWithTransaction

server/resource/dbmethods.go:3163–3202

GetReferenceIdToIdWithTransaction Looks up a string reference id and return an internal integer id of an object of type `typeName`

(typeName string, referenceId daptinid.DaptinReferenceId, updateTransaction *sqlx.Tx)

// GetReferenceIdToIdWithTransaction Looks up a string reference id and return an internal integer id of an object of type `typeName`
func GetReferenceIdToIdWithTransaction(typeName string, referenceId daptinid.DaptinReferenceId, updateTransaction *sqlx.Tx) (int64, error) {

	cacheKey := fmt.Sprintf("riti-%v-%v", typeName, referenceId)

	if OlricCache != nil {

		cachedValue, err := OlricCache.Get(context.Background(), cacheKey)
		if err == nil && cachedValue != nil {
			return cachedValue.Int64()
		}
	}

	var id int64
	s, q, err := statementbuilder.Squirrel.Select("id").
		Prepared(true).From(typeName).Where(goqu.Ex{"reference_id": referenceId[:]}).ToSQL()
	if err != nil {
		return 0, err
	}
	stmt, err := updateTransaction.Preparex(s)
	if err != nil {
		log.Errorf("[1666] failed to prepare statment: %v", err)
		return 0, err
	}
	defer func(stmt1 *sqlx.Stmt) {
		err := stmt1.Close()
		if err != nil {
			log.Errorf("failed to close prepared statement: %v", err)
		}
	}(stmt)

	err = stmt.QueryRowx(q...).Scan(&id)

	if OlricCache != nil && err == nil {
		cachePutErr := OlricCache.Put(context.Background(), cacheKey, id, olric.EX(1*time.Hour), olric.NX())
		CheckErr(cachePutErr, "failed to cache reference id to id for [%v][%v]", typeName, referenceId)
	}

	return id, err

}

// Lookup an string reference id and return a internal integer id of an object of type `typeName`
func (dbResource *DbResource) GetReferenceIdListToIdList(typeName string, referenceId []string) (map[string]int64, error) {