30 lines
533 B
Go
30 lines
533 B
Go
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("入库一条数据")
|
|
}
|
|
}
|
|
}
|