conn

Documentation

Index

• type DB
  • func (db *DB) CloseDatabase()
  • func (db *DB) ConnectDatabase()
  • func (db *DB) DynamicCount(builder *gobuilder.GoBuilder) (int, error)
  • func (db *DB) DynamicCreate(builder *gobuilder.GoBuilder) (int, error)
  • func (db *DB) DynamicFind(builder *gobuilder.GoBuilder, model any) error
  • func (db *DB) DynamicGet(builder *gobuilder.GoBuilder, model any) ([]any, error)
  • func (db *DB) DynamicPaginate(builder *gobuilder.GoBuilder, model any) ([]any, error)
  • func (db *DB) DynamicUpdate(builder *gobuilder.GoBuilder) error
  • func (db *DB) ExistsInTable(builder *gobuilder.GoBuilder) error
  • func (db *DB) HardDelete(builder *gobuilder.GoBuilder) error
  • func (db *DB) NotExistsInTable(builder *gobuilder.GoBuilder) error
  • func (db *DB) QueryExec(builder *gobuilder.GoBuilder) error
  • func (db *DB) SoftDelete(builder *gobuilder.GoBuilder) error
• type Kafka
  • func (k *Kafka) CloseKafka()
  • func (k *Kafka) ConnectKafka()
  • func (k *Kafka) PushCommentToQueue(topic string, message []byte) error
• type Redis
  • func (r *Redis) CloseRedis()
  • func (r *Redis) ConnectRedis()
  • func (r *Redis) RedisRead() (string, error)
  • func (r *Redis) RedisWrite() error

Types

type DB

type DB struct {
	*sql.DB
}

func (*DB) CloseDatabase

func (db *DB) CloseDatabase()

CloseDatabase method is closing a connection between your app and your db

func (*DB) ConnectDatabase

func (db *DB) ConnectDatabase()

ConnectDatabase is creating a new connection to our database

func (*DB) DynamicCount

func (db *DB) DynamicCount(builder *gobuilder.GoBuilder) (int, error)

DynamicCount: returns the number of data according to the conditions

func (*DB) DynamicCreate

func (db *DB) DynamicCreate(builder *gobuilder.GoBuilder) (int, error)

DynamicCreate: the specified values are recorded in the specified table.

func (*DB) DynamicFind

func (db *DB) DynamicFind(builder *gobuilder.GoBuilder, model any) error

DynamicFind: only renders the first matching record to the p.Model object based on the conditions

func (*DB) DynamicGet

func (db *DB) DynamicGet(builder *gobuilder.GoBuilder, model any) ([]any, error)

DynamicGet: returns all records it finds

func (*DB) DynamicPaginate

func (db *DB) DynamicPaginate(builder *gobuilder.GoBuilder, model any) ([]any, error)

DynamicPaginate: returns all records according to the conditions

func (*DB) DynamicUpdate

func (db *DB) DynamicUpdate(builder *gobuilder.GoBuilder) error

DynamicUpdate: the values specified in the table are updated.

func (*DB) ExistsInTable

func (db *DB) ExistsInTable(builder *gobuilder.GoBuilder) error

ExistsInTable: If exists, return "nil".

func (*DB) HardDelete

func (db *DB) HardDelete(builder *gobuilder.GoBuilder) error

HardDelete: hard delete the specified id in the specified table.

func (*DB) NotExistsInTable

func (db *DB) NotExistsInTable(builder *gobuilder.GoBuilder) error

NotExistsInTable: If not exists, return "nil".

func (*DB) QueryExec

func (db *DB) QueryExec(builder *gobuilder.GoBuilder) error

QueryExec: returns nil if the query is executed successfully

func (*DB) SoftDelete

func (db *DB) SoftDelete(builder *gobuilder.GoBuilder) error

SoftDelete: soft delete the specified id in the specified table.

type Kafka

type Kafka struct {
	sarama.SyncProducer
}

func (*Kafka) CloseKafka

func (k *Kafka) CloseKafka()

func (*Kafka) ConnectKafka

func (k *Kafka) ConnectKafka()

func (*Kafka) PushCommentToQueue

func (k *Kafka) PushCommentToQueue(topic string, message []byte) error

type Redis

type Redis struct {
	*redis.Client
}

func (*Redis) CloseRedis

func (r *Redis) CloseRedis()

func (*Redis) ConnectRedis

func (r *Redis) ConnectRedis()

func (*Redis) RedisRead

func (r *Redis) RedisRead() (string, error)

func (*Redis) RedisWrite

func (r *Redis) RedisWrite() error