Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package database
- import (
- "fmt"
- "time"
- "database/sql"
- _ "github.com/lib/pq"
- "github.com/thrasher-/gocryptotrader/config"
- )
- const CLIENT_TABLE = `
- CREATE TABLE tickerData
- (
- exchangeName character
- currencyPair character
- last float64
- high float64
- low float64
- bid float64
- ask float64
- volume float64
- inserted
- )
- WITH (OIDS=FALSE);
- `
- //Databasethingy main db struct and stuff that init variables
- type Databasethingy struct {
- //clientinfo map[string] /*ExchangeName*/ clientDetails
- tickerData map[string] /*ExchangeName*/ exchangeData
- configData []byte
- DBUser string
- DBPassword string
- DBName string
- Verbose bool
- }
- // type clientDetails struct {
- // Username string
- // Password string
- // APIKey string
- // APISecret string
- // Email string
- // }
- type exchangeData struct {
- ticker map[string] /*CurrrencyPair*/ tickerData
- }
- type tickerData struct {
- Last float64
- High float64
- Low float64
- Bid float64
- Ask float64
- Volume float64
- time time.Time
- }
- func (d *Databasethingy) SetDefaults() {
- d.DBUser = "gctbot"
- d.DBPassword = "1337"
- d.DBName = "gctdb"
- d.Verbose = false
- }
- func (d *Databasethingy) Setup(configPath string) error {
- configRunner := config.GetConfig()
- err := configRunner.LoadConfig(configPath)
- if err != nil {
- return err
- }
- //d.exchangeInfo = make(map[string]config.ExchangeConfig)
- //d.clientinfo = make(map[string]clientDetails)
- d.tickerData = make(map[string]exchangeData)
- // for _, something := range configRunner.Exchanges {
- // d.exchangeInfo[something.Name] = something
- // }
- return nil
- }
- //RunDB something something rawr
- func (d *Databasethingy) RunDB() error {
- d.SetDefaults()
- d.Setup("../testdata/configtest.dat")
- dbInfo := fmt.Sprintf("user=%s password=%s dbname=%s sslmode=disable",
- d.DBUser, d.DBPassword, d.DBName)
- db, err := sql.Open("postgres", dbInfo)
- if err != nil {
- return err
- }
- defer db.Close()
- err = db.Ping()
- if err != nil {
- return err
- }
- return nil
- }
- func (d *Databasethingy) setDBTables() {
- }
- // func createTable() {
- //
- // }
- //
- // func insertValue() {
- //
- // }
- // func updateExchangeInfo() {
- //
- // }
- // func updateTickerInfo() {
- //
- // }
- //
- // func query() {
- //
- // }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement