db

package
v0.0.0-...-07d2a04 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 21, 2024 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CreateSensorMetadataParams 

type CreateSensorMetadataParams struct {
	ID             int32       `db:"id" json:"id"`
	SensorID       int32       `db:"sensor_id" json:"sensor_id"`
	SensorType     pgtype.Text `db:"sensor_type" json:"sensor_type"`
	Manufacturer   pgtype.Text `db:"manufacturer" json:"manufacturer"`
	ModelNumber    pgtype.Text `db:"model_number" json:"model_number"`
	SensorLocation pgtype.Text `db:"sensor_location" json:"sensor_location"`
	AdditionalData []byte      `db:"additional_data" json:"additional_data"`
}

type CreateSensorParams 

type CreateSensorParams struct {
	SensorName string             `db:"sensor_name" json:"sensor_name"`
	CreatedAt  pgtype.Timestamptz `db:"created_at" json:"created_at"`
	UpdatedAt  pgtype.Timestamptz `db:"updated_at" json:"updated_at"`
}

type CreateSensorReadingParams 

type CreateSensorReadingParams struct {
	ReadingTimestamp pgtype.Timestamptz `db:"reading_timestamp" json:"reading_timestamp"`
	SensorID         pgtype.Int4        `db:"sensor_id" json:"sensor_id"`
	Temperature      pgtype.Float8      `db:"temperature" json:"temperature"`
	Humidity         pgtype.Float8      `db:"humidity" json:"humidity"`
}

type DBTX 

type DBTX interface {
	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
	QueryRow(context.Context, string, ...interface{}) pgx.Row
}

type GetSensorMetadataParams 

type GetSensorMetadataParams struct {
	Limit  int32 `db:"limit" json:"limit"`
	Offset int32 `db:"offset" json:"offset"`
}

type GetSensorReadingDailByIdParams 

type GetSensorReadingDailByIdParams struct {
	SensorID pgtype.Int4 `db:"sensor_id" json:"sensor_id"`
	Limit    int32       `db:"limit" json:"limit"`
	Offset   int32       `db:"offset" json:"offset"`
}

type GetSensorReadingDailyParams 

type GetSensorReadingDailyParams struct {
	Limit  int32 `db:"limit" json:"limit"`
	Offset int32 `db:"offset" json:"offset"`
}

type GetSensorReadingHourlyByIdParams 

type GetSensorReadingHourlyByIdParams struct {
	SensorID pgtype.Int4 `db:"sensor_id" json:"sensor_id"`
	Limit    int32       `db:"limit" json:"limit"`
	Offset   int32       `db:"offset" json:"offset"`
}

type GetSensorReadingHourlyParams 

type GetSensorReadingHourlyParams struct {
	Limit  int32 `db:"limit" json:"limit"`
	Offset int32 `db:"offset" json:"offset"`
}

type GetSensorReadingMinutesByIdParams 

type GetSensorReadingMinutesByIdParams struct {
	SensorID pgtype.Int4 `db:"sensor_id" json:"sensor_id"`
	Limit    int32       `db:"limit" json:"limit"`
	Offset   int32       `db:"offset" json:"offset"`
}

type GetSensorReadingMinutesParams 

type GetSensorReadingMinutesParams struct {
	Limit  int32 `db:"limit" json:"limit"`
	Offset int32 `db:"offset" json:"offset"`
}

type GetSensorReadingParams 

type GetSensorReadingParams struct {
	SensorID pgtype.Int4 `db:"sensor_id" json:"sensor_id"`
	Limit    int32       `db:"limit" json:"limit"`
	Offset   int32       `db:"offset" json:"offset"`
}

type GetSensorsParams 

type GetSensorsParams struct {
	Limit  int32 `db:"limit" json:"limit"`
	Offset int32 `db:"offset" json:"offset"`
}

type Querier 

type Querier interface {
	//CreateSensor
	//
	//  INSERT INTO sensors (sensor_name, created_at, updated_at)
	//  VALUES ($1, $2, $3)
	//  RETURNING id, sensor_name, created_at, updated_at
	CreateSensor(ctx context.Context, arg CreateSensorParams) (Sensor, error)
	//CreateSensorMetadata
	//
	//  INSERT INTO sensor_metadata ( id, sensor_id, sensor_type, manufacturer, model_number, sensor_location, additional_data )
	//  VALUES ($1, $2, $3, $4, $5, $6, $7)
	//  RETURNING id, sensor_type, manufacturer, model_number, sensor_location, installation_time, updated_at, additional_data, sensor_id
	CreateSensorMetadata(ctx context.Context, arg CreateSensorMetadataParams) (SensorMetadatum, error)
	//CreateSensorReading
	//
	//  INSERT INTO sensor_readings (sensor_id, temperature, humidity)
	//  VALUES ($1, $2, $3)
	//  RETURNING reading_timestamp, sensor_id, temperature, humidity, pressure
	CreateSensorReading(ctx context.Context, arg CreateSensorReadingParams) (SensorReading, error)
	//DeleteSensor
	//
	//  DELETE FROM sensors WHERE id=$1
	DeleteSensor(ctx context.Context, id int32) (pgconn.CommandTag, error)
	//DeleteSensorMetadata
	//
	//  DELETE FROM sensor_metadata WHERE id = $1
	DeleteSensorMetadata(ctx context.Context, id int32) (pgconn.CommandTag, error)
	//GetSensorById
	//
	//  SELECT id, sensor_name, created_at, updated_at FROM sensors WHERE id=$1
	GetSensorById(ctx context.Context, id int32) (Sensor, error)
	//GetSensorByName
	//
	//  SELECT id, sensor_name, created_at, updated_at FROM sensors WHERE sensor_name=$1
	GetSensorByName(ctx context.Context, sensorName string) (Sensor, error)
	//GetSensorMetadata
	//
	//  SELECT id, sensor_type, manufacturer, model_number, sensor_location, installation_time, updated_at, additional_data, sensor_id
	//  FROM sensor_metadata
	//  LIMIT $1 OFFSET $2
	GetSensorMetadata(ctx context.Context, arg GetSensorMetadataParams) ([]SensorMetadatum, error)
	//GetSensorMetadataForSensorId
	//
	//  SELECT sensors.id, sensors.sensor_name, sensors.created_at, sensors.updated_at
	//  FROM sensors
	//           JOIN sensor_metadata ON sensors.id = sensor_metadata.sensor_id
	//  WHERE sensor_metadata.sensor_id = $1
	GetSensorMetadataForSensorId(ctx context.Context, sensorID int32) (Sensor, error)
	//GetSensorReading
	//
	//  SELECT reading_timestamp, sensor_id, temperature, humidity, pressure
	//  FROM sensor_readings
	//  WHERE sensor_id = $1
	//  LIMIT $2 OFFSET $3
	GetSensorReading(ctx context.Context, arg GetSensorReadingParams) ([]SensorReading, error)
	//GetSensorReadingDaily
	//
	//  SELECT day, sensor_id, min_temperature, avg_temperature, max_temperature, min_humidity, avg_humidity, max_humidity
	//  FROM sensor_readings_daily
	//  LIMIT $1 OFFSET $2
	GetSensorReadingDaily(ctx context.Context, arg GetSensorReadingDailyParams) ([]SensorReadingsDaily, error)
	//GetSensorReadingHourly
	//
	//  SELECT hour, sensor_id, min_temperature, avg_temperature, max_temperature, min_humidity, avg_humidity, max_humidity
	//  FROM sensor_readings_hourly
	//  LIMIT $1 OFFSET $2
	GetSensorReadingHourly(ctx context.Context, arg GetSensorReadingHourlyParams) ([]SensorReadingsHourly, error)
	//GetSensorReadingMinutes
	//
	//  SELECT minute, sensor_id, min_temperature, avg_temperature, max_temperature, min_humidity, avg_humidity, max_humidity
	//  FROM sensor_readings_minutes
	//  LIMIT $1 OFFSET $2
	GetSensorReadingMinutes(ctx context.Context, arg GetSensorReadingMinutesParams) ([]SensorReadingsMinute, error)
	//GetSensors
	//
	//  SELECT id, sensor_name, created_at, updated_at FROM sensors LIMIT $1 OFFSET $2
	GetSensors(ctx context.Context, arg GetSensorsParams) ([]Sensor, error)
	//UpdateSensor
	//
	//  UPDATE sensors
	//  SET sensor_name = $2, updated_at = now()
	//  WHERE id = $1
	//  RETURNING id, sensor_name, created_at, updated_at
	UpdateSensor(ctx context.Context, arg UpdateSensorParams) (pgconn.CommandTag, error)
	//UpdateSensorMetadata
	//
	//  UPDATE sensor_metadata
	//  SET sensor_id = $1, sensor_type = $3, manufacturer = $4, model_number = $5, sensor_location = $6, additional_data = $7
	//  WHERE id = $2
	//  RETURNING id, sensor_type, manufacturer, model_number, sensor_location, installation_time, updated_at, additional_data, sensor_id
	UpdateSensorMetadata(ctx context.Context, arg UpdateSensorMetadataParams) (pgconn.CommandTag, error)
}

type Queries 

type Queries struct {
	// contains filtered or unexported fields
}

func New 

func New(db DBTX) *Queries

func (*Queries) CreateSensor 

func (q *Queries) CreateSensor(ctx context.Context, arg CreateSensorParams) (Sensor, error)

CreateSensor 

INSERT INTO sensors (sensor_name, created_at, updated_at)
VALUES ($1, $2, $3)
RETURNING id, sensor_name, created_at, updated_at

func (*Queries) CreateSensorMetadata 

func (q *Queries) CreateSensorMetadata(ctx context.Context, arg CreateSensorMetadataParams) (SensorMetadatum, error)

CreateSensorMetadata 

INSERT INTO sensor_metadata ( id, sensor_id, sensor_type, manufacturer, model_number, sensor_location, additional_data )
VALUES ($1, $2, $3, $4, $5, $6, $7)
RETURNING id, sensor_type, manufacturer, model_number, sensor_location, installation_time, updated_at, additional_data, sensor_id

func (*Queries) CreateSensorReading 

func (q *Queries) CreateSensorReading(ctx context.Context, arg CreateSensorReadingParams) (SensorReading, error)

CreateSensorReading 

INSERT INTO sensor_readings (reading_timestamp, sensor_id, temperature, humidity)
VALUES ($1, $2, $3, $4)
RETURNING reading_timestamp, sensor_id, temperature, humidity, pressure

func (*Queries) DeleteSensor 

func (q *Queries) DeleteSensor(ctx context.Context, id int32) (pgconn.CommandTag, error)

DeleteSensor 

DELETE FROM sensors WHERE id=$1

func (*Queries) DeleteSensorMetadata 

func (q *Queries) DeleteSensorMetadata(ctx context.Context, id int32) (pgconn.CommandTag, error)

DeleteSensorMetadata 

DELETE FROM sensor_metadata WHERE id = $1

func (*Queries) GetSensorById 

func (q *Queries) GetSensorById(ctx context.Context, id int32) (Sensor, error)

GetSensorById 

SELECT id, sensor_name, created_at, updated_at FROM sensors WHERE id=$1

func (*Queries) GetSensorByName 

func (q *Queries) GetSensorByName(ctx context.Context, sensorName string) (Sensor, error)

GetSensorByName 

SELECT id, sensor_name, created_at, updated_at FROM sensors WHERE sensor_name=$1

func (*Queries) GetSensorMetadata 

func (q *Queries) GetSensorMetadata(ctx context.Context, arg GetSensorMetadataParams) ([]SensorMetadatum, error)

GetSensorMetadata 

SELECT id, sensor_type, manufacturer, model_number, sensor_location, installation_time, updated_at, additional_data, sensor_id
FROM sensor_metadata
LIMIT $1 OFFSET $2

func (*Queries) GetSensorMetadataForSensorId 

func (q *Queries) GetSensorMetadataForSensorId(ctx context.Context, sensorID int32) (Sensor, error)

GetSensorMetadataForSensorId 

SELECT sensors.id, sensors.sensor_name, sensors.created_at, sensors.updated_at
FROM sensors
         JOIN sensor_metadata ON sensors.id = sensor_metadata.sensor_id
WHERE sensor_metadata.sensor_id = $1

func (*Queries) GetSensorReading 

func (q *Queries) GetSensorReading(ctx context.Context, arg GetSensorReadingParams) ([]SensorReading, error)

GetSensorReading 

SELECT reading_timestamp, sensor_id, temperature, humidity, pressure
FROM sensor_readings
WHERE sensor_id = $1
LIMIT $2 OFFSET $3

func (*Queries) GetSensorReadingDailById 

func (q *Queries) GetSensorReadingDailById(ctx context.Context, arg GetSensorReadingDailByIdParams) ([]SensorReadingsDaily, error)

GetSensorReadingDailById 

SELECT day, sensor_id, min_temperature, avg_temperature, max_temperature, min_humidity, avg_humidity, max_humidity
FROM sensor_readings_daily
WHERE sensor_id = $1
LIMIT $2 OFFSET $3

func (*Queries) GetSensorReadingDaily 

func (q *Queries) GetSensorReadingDaily(ctx context.Context, arg GetSensorReadingDailyParams) ([]SensorReadingsDaily, error)

GetSensorReadingDaily 

SELECT day, sensor_id, min_temperature, avg_temperature, max_temperature, min_humidity, avg_humidity, max_humidity
FROM sensor_readings_daily
LIMIT $1 OFFSET $2

func (*Queries) GetSensorReadingHourly 

func (q *Queries) GetSensorReadingHourly(ctx context.Context, arg GetSensorReadingHourlyParams) ([]SensorReadingsHourly, error)

GetSensorReadingHourly 

SELECT hour, sensor_id, min_temperature, avg_temperature, max_temperature, min_humidity, avg_humidity, max_humidity
FROM sensor_readings_hourly
LIMIT $1 OFFSET $2

func (*Queries) GetSensorReadingHourlyById 

func (q *Queries) GetSensorReadingHourlyById(ctx context.Context, arg GetSensorReadingHourlyByIdParams) ([]SensorReadingsHourly, error)

GetSensorReadingHourlyById 

SELECT hour, sensor_id, min_temperature, avg_temperature, max_temperature, min_humidity, avg_humidity, max_humidity
FROM sensor_readings_hourly
WHERE sensor_id = $1
LIMIT $2 OFFSET $3

func (*Queries) GetSensorReadingMinutes 

func (q *Queries) GetSensorReadingMinutes(ctx context.Context, arg GetSensorReadingMinutesParams) ([]SensorReadingsMinute, error)

GetSensorReadingMinutes 

SELECT minute, sensor_id, min_temperature, avg_temperature, max_temperature, min_humidity, avg_humidity, max_humidity
FROM sensor_readings_minutes
LIMIT $1 OFFSET $2

func (*Queries) GetSensorReadingMinutesById 

func (q *Queries) GetSensorReadingMinutesById(ctx context.Context, arg GetSensorReadingMinutesByIdParams) ([]SensorReadingsMinute, error)

GetSensorReadingMinutesById 

SELECT minute, sensor_id, min_temperature, avg_temperature, max_temperature, min_humidity, avg_humidity, max_humidity
FROM sensor_readings_minutes
WHERE sensor_id = $1
LIMIT $2 OFFSET $3

func (*Queries) GetSensors 

func (q *Queries) GetSensors(ctx context.Context, arg GetSensorsParams) ([]Sensor, error)

GetSensors 

SELECT id, sensor_name, created_at, updated_at FROM sensors LIMIT $1 OFFSET $2

func (*Queries) UpdateSensor 

func (q *Queries) UpdateSensor(ctx context.Context, arg UpdateSensorParams) (pgconn.CommandTag, error)

UpdateSensor 

UPDATE sensors
SET sensor_name = $2, updated_at = now()
WHERE id = $1
RETURNING id, sensor_name, created_at, updated_at

func (*Queries) UpdateSensorMetadata 

func (q *Queries) UpdateSensorMetadata(ctx context.Context, arg UpdateSensorMetadataParams) (pgconn.CommandTag, error)

UpdateSensorMetadata 

UPDATE sensor_metadata
SET sensor_id = $1, sensor_type = $3, manufacturer = $4, model_number = $5, sensor_location = $6, additional_data = $7
WHERE id = $2
RETURNING id, sensor_type, manufacturer, model_number, sensor_location, installation_time, updated_at, additional_data, sensor_id

func (*Queries) WithTx 

func (q *Queries) WithTx(tx pgx.Tx) *Queries

type Sensor 

type Sensor struct {
	ID         int32              `db:"id" json:"id"`
	SensorName string             `db:"sensor_name" json:"sensor_name"`
	CreatedAt  pgtype.Timestamptz `db:"created_at" json:"created_at"`
	UpdatedAt  pgtype.Timestamptz `db:"updated_at" json:"updated_at"`
}

type SensorMetadatum 

type SensorMetadatum struct {
	ID               int32              `db:"id" json:"id"`
	SensorType       pgtype.Text        `db:"sensor_type" json:"sensor_type"`
	Manufacturer     pgtype.Text        `db:"manufacturer" json:"manufacturer"`
	ModelNumber      pgtype.Text        `db:"model_number" json:"model_number"`
	SensorLocation   pgtype.Text        `db:"sensor_location" json:"sensor_location"`
	InstallationTime pgtype.Timestamptz `db:"installation_time" json:"installation_time"`
	UpdatedAt        pgtype.Timestamptz `db:"updated_at" json:"updated_at"`
	AdditionalData   []byte             `db:"additional_data" json:"additional_data"`
	SensorID         int32              `db:"sensor_id" json:"sensor_id"`
}

type SensorReading 

type SensorReading struct {
	ReadingTimestamp pgtype.Timestamptz `db:"reading_timestamp" json:"reading_timestamp"`
	SensorID         pgtype.Int4        `db:"sensor_id" json:"sensor_id"`
	Temperature      pgtype.Float8      `db:"temperature" json:"temperature"`
	Humidity         pgtype.Float8      `db:"humidity" json:"humidity"`
	Pressure         pgtype.Float8      `db:"pressure" json:"pressure"`
}

type SensorReadingsDaily 

type SensorReadingsDaily struct {
	Day            interface{} `db:"day" json:"day"`
	SensorID       pgtype.Int4 `db:"sensor_id" json:"sensor_id"`
	MinTemperature interface{} `db:"min_temperature" json:"min_temperature"`
	AvgTemperature float64     `db:"avg_temperature" json:"avg_temperature"`
	MaxTemperature interface{} `db:"max_temperature" json:"max_temperature"`
	MinHumidity    interface{} `db:"min_humidity" json:"min_humidity"`
	AvgHumidity    float64     `db:"avg_humidity" json:"avg_humidity"`
	MaxHumidity    interface{} `db:"max_humidity" json:"max_humidity"`
}

type SensorReadingsHourly 

type SensorReadingsHourly struct {
	Hour           interface{} `db:"hour" json:"hour"`
	SensorID       pgtype.Int4 `db:"sensor_id" json:"sensor_id"`
	MinTemperature interface{} `db:"min_temperature" json:"min_temperature"`
	AvgTemperature float64     `db:"avg_temperature" json:"avg_temperature"`
	MaxTemperature interface{} `db:"max_temperature" json:"max_temperature"`
	MinHumidity    interface{} `db:"min_humidity" json:"min_humidity"`
	AvgHumidity    float64     `db:"avg_humidity" json:"avg_humidity"`
	MaxHumidity    interface{} `db:"max_humidity" json:"max_humidity"`
}

type SensorReadingsMinute 

type SensorReadingsMinute struct {
	Minute         interface{} `db:"minute" json:"minute"`
	SensorID       pgtype.Int4 `db:"sensor_id" json:"sensor_id"`
	MinTemperature interface{} `db:"min_temperature" json:"min_temperature"`
	AvgTemperature float64     `db:"avg_temperature" json:"avg_temperature"`
	MaxTemperature interface{} `db:"max_temperature" json:"max_temperature"`
	MinHumidity    interface{} `db:"min_humidity" json:"min_humidity"`
	AvgHumidity    float64     `db:"avg_humidity" json:"avg_humidity"`
	MaxHumidity    interface{} `db:"max_humidity" json:"max_humidity"`
}

type UpdateSensorMetadataParams 

type UpdateSensorMetadataParams struct {
	SensorID       int32       `db:"sensor_id" json:"sensor_id"`
	ID             int32       `db:"id" json:"id"`
	SensorType     pgtype.Text `db:"sensor_type" json:"sensor_type"`
	Manufacturer   pgtype.Text `db:"manufacturer" json:"manufacturer"`
	ModelNumber    pgtype.Text `db:"model_number" json:"model_number"`
	SensorLocation pgtype.Text `db:"sensor_location" json:"sensor_location"`
	AdditionalData []byte      `db:"additional_data" json:"additional_data"`
}

type UpdateSensorParams 

type UpdateSensorParams struct {
	ID         int32  `db:"id" json:"id"`
	SensorName string `db:"sensor_name" json:"sensor_name"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.