mysql

Documentation

Index

• Constants
• type DBHelper
  • func (db *DBHelper) ConnectToDB(ctx context.Context) error
  • func (db *DBHelper) InsertDataToDB(ctx context.Context, deviceName string, rawData []byte) error
  • func (db *DBHelper) SendToDB(ctx context.Context, deviceName string, rawData []byte) error

Constants

const (
	TIMESTAMP_FORMAT = "2006-01-02 15:04:05"
	MYSQL_URL_FORMAT = "%s:%s@(%s)/%s"
	MYSQL_QUERY      = "Insert Into %s (DeviceName,TelemetryData,TelemetryTimeStamp) Values('%s','%s','%s')"
	MYSQL            = "mysql"
)

Types

type DBHelper

type DBHelper struct {
	DB       *sql.DB
	Settings *v1alpha1.SQLConnectionSetting
}

func (*DBHelper) ConnectToDB

func (db *DBHelper) ConnectToDB(ctx context.Context) error

func (*DBHelper) InsertDataToDB

func (db *DBHelper) InsertDataToDB(ctx context.Context, deviceName string, rawData []byte) error

This table stores telemetry data from various devices. CREATE TABLE ${DbTableName} (

    TelemetryID INT AUTO_INCREMENT PRIMARY KEY,
    DeviceName VARCHAR(255),
    TelemetryData TEXT,
    TelemetryTimeStamp TIMESTAMP
)

The table is used to track telemetry information for analysis and monitoring.

func (*DBHelper) SendToDB

func (db *DBHelper) SendToDB(ctx context.Context, deviceName string, rawData []byte) error