package logstorage

import (
	"database/sql"
	"fmt"
	"log_storage/logparse"
)

func PgsqlStorageStart(logchan <-chan *logparse.Log, dbconn string) {

	db, err := sql.Open("postgres", dbconn)

	if err != nil {
		panic("pgsql连接失败")
	}

	for log := range logchan {

		sql := "INSERT INTO psiplog (time,title,message,level,app) VALUES($1,$2,$3,$4,$5);"

		_, err := db.Exec(sql, log.Time, log.Title, log.Message, log.Level, log.App)

		if err != nil {
			fmt.Println(err)
		} else {
			fmt.Println("入库一条数据")
		}
	}
}