初始提交

Infrastructure/log_storage/logstorage/logstorage.go

@@ -0,0 +1,29 @@
+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("入库一条数据")
+		}
+	}
+}