sqlserver

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"
	SQLSERVER_URL_FORMAT = "sqlserver://%s:%s@%s?database=%s"
	SQLSERVER_QUERY      = "Insert Into %s (DeviceName,TelemetryData,TelemetryTimeStamp) Values('%s','%s','%s')"
	SQLSERVER            = "sqlserver"
)

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 IDENTITY(1,1) PRIMARY KEY,
	DeviceName VARCHAR(255),
    TelemetryData TEXT,
    TelemetryTimeStamp DATETIME

) 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