package mysql import ( "context" "git.aiterp.net/lucifer/new-server/models" "github.com/jmoiron/sqlx" ) type BridgeRepo struct { DBX *sqlx.DB } func (b *BridgeRepo) Find(ctx context.Context, id int) (models.Bridge, error) { var bridge models.Bridge err := b.DBX.GetContext(ctx, &bridge, "SELECT * FROM bridge WHERE id = ?", id) if err != nil { return models.Bridge{}, dbErr(err) } return bridge, nil } func (b *BridgeRepo) FetchAll(ctx context.Context) ([]models.Bridge, error) { bridges := make([]models.Bridge, 0, 8) err := b.DBX.SelectContext(ctx, &bridges, "SELECT * FROM bridge") if err != nil { return nil, dbErr(err) } return bridges, nil } func (b *BridgeRepo) Save(ctx context.Context, bridge *models.Bridge) error { if bridge.ID > 0 { _, err := b.DBX.ExecContext( ctx, "UPDATE bridge SET name = ?, address = ?, token = ? WHERE id = ?", bridge.Name, bridge.Address, bridge.Token, bridge.ID, ) if err != nil { return dbErr(err) } } else { rs, err := b.DBX.ExecContext( ctx, "INSERT INTO bridge (name, driver, address, token) VALUES (?, ?, ?, ?)", bridge.Name, bridge.Driver, bridge.Address, bridge.Token, ) if err != nil { return dbErr(err) } id, err := rs.LastInsertId() if err != nil { return dbErr(err) } bridge.ID = int(id) } return nil } func (b *BridgeRepo) Delete(ctx context.Context, bridge *models.Bridge) error { _, err := b.DBX.ExecContext(ctx, "DELETE FROM bridge WHERE id = ?", bridge.ID) if err != nil { return dbErr(err) } _, err = b.DBX.ExecContext(ctx, "DELETE FROM device WHERE bridge_id = ?", bridge.ID) if err != nil { return dbErr(err) } bridge.ID = 0 return nil }