plgo-db-test

package main

import (
	"log"
	"strings"

	"github.com/microo8/plgo"
)

//Meh prints out message to error elog
func Meh() {
	logger := plgo.NewErrorLogger("", log.Ltime|log.Lshortfile)
	logger.Println("meh")
}

//ConcatAll concatenates all values of an column in a given table
func ConcatAll(tableName, colName string) string {
	logger := plgo.NewErrorLogger("", log.Ltime|log.Lshortfile)
	db, err := plgo.Open()
	if err != nil {
		logger.Fatalf("Cannot open DB: %s", err)
	}
	defer db.Close()
	query := "select " + colName + " from " + tableName + " limit 1"
	stmt, err := db.Prepare(query, nil)
	if err != nil {
		logger.Fatalf("Cannot prepare query statement (%s): %s", query, err)
	}
	row, err := stmt.QueryRow()
	if err != nil {
		logger.Fatalf("Query (%s) error: %s", query, err)
	}
        var val string
	err = row.Scan(&val)
	if err != nil {
	       logger.Fatalln("Cannot scan value", err)
	}
	return val
}

//CreatedTimeTrigger example trigger
func CreatedTimeTrigger(td *plgo.TriggerData) *plgo.TriggerRow {
	var id int
	var value string
	td.NewRow.Scan(&id, &value)
	td.NewRow.Set(0, id+10)
	td.NewRow.Set(1, value+value)
	return td.NewRow
}

//ConcatArray concatenates an array of strings
func ConcatArray(strs []string) string {
	return strings.Join(strs, "")
}