Embedded postgresql using golang - Revision history

Busk at 03:21, 12 March 2022

2022-03-12T03:21:39Z

Busk at 03:50, 11 March 2022

2022-03-11T03:50:40Z

Busk at 03:49, 11 March 2022

2022-03-11T03:49:48Z

Busk at 03:48, 11 March 2022

2022-03-11T03:48:47Z

Busk: Created page with "package main /* https://pkg.go.dev/github.com/fergusstrange/embedded-postgres#section-readme https://github.com/fergusstrange/embedded-postgres https://github.com/zonkyio/embe..."

2022-03-11T03:47:19Z

Created page with "package main /* https://pkg.go.dev/github.com/fergusstrange/embedded-postgres#section-readme https://github.com/fergusstrange/embedded-postgres https://github.com/zonkyio/embe..."

New page

package main
/*
https://pkg.go.dev/github.com/fergusstrange/embedded-postgres#section-readme
https://github.com/fergusstrange/embedded-postgres
https://github.com/zonkyio/embedded-postgres
https://mvnrepository.com/artifact/io.zonky.test.postgres/embedded-postgres-binaries-bom
*/

import (
"bytes"
"fmt"
"time"

"github.com/fergusstrange/embedded-postgres"
)

func main() {
runseconds := 60
// Version("14.2.0").
// Version("13.6.0").
// Version("12.10.0").
logger := &bytes.Buffer{}
conf := embeddedpostgres.DefaultConfig().
Username("demo").
Password("demo").
Database("demo").
Version("14.2.0").
RuntimePath("./pgdata").
BinaryRepositoryURL("https://repo1.maven.org/maven2").
Port(15432).
StartTimeout(15 * time.Second).
Logger(logger)

postgres := embeddedpostgres.NewDatabase(conf)
err := postgres.Start()
if err != nil {
fmt.Println(err)
}

fmt.Printf("Running postgres server for %d seconds.", runseconds)
time.Sleep(time.Duration(runseconds) * time.Second)

err = postgres.Stop()
if err != nil {
fmt.Println(err)
}
}

@@ Line 1: / Line 1: @@
-.env
+nano .env
 ```
 export PGDATABASE=demo
@@ Line 8: / Line 8: @@
 ```
-get package
+Source
 ```
 go get -u github.com/fergusstrange/embedded-postgres
 ```
-runpg.go
+nano runpg.go
 ```
 package main

@@ Line 13: / Line 13: @@
 ```
-a.go
+runpg.go
 ```
 package main
@@ Line 62: / Line 62: @@
+                 }
+}
 ```

@@ Line 1: / Line 1: @@
 package main
 /*
@@ Line 46: / Line 62: @@
+                 }
+}

@@ Line 21: / Line 21: @@
 ```
 package main
 /*
 https://pkg.go.dev/github.com/fergusstrange/embedded-postgres#section-readme
@@ Line 29: / Line 30: @@
 import (
-        "bytes"
+    "bytes"
-        "fmt"
+    "fmt"
-        "time"
+    "os"
-        "github.com/fergusstrange/embedded-postgres"
+    "github.com/drael/GOnetstat"
+)
 func main() {
-        runseconds := 60
+    port := 9999
          // Version("14.2.0").
-         // Version("13.6.0").
+         Version("12.10.0").
-        // Version("12.10.0").
+         RuntimePath("./runtime").
-         logger := &bytes.Buffer{}
+        BinariesPath("./bin").
-        conf := embeddedpostgres.DefaultConfig().
+        DataPath("./data").
-                Username("demo").
+        BinaryRepositoryURL("https://repo1.maven.org/maven2").
-                Password("demo").
+        Port(port32).
-                Database("demo").
+        StartTimeout(15 * time.Second).
-                Version("14.2.0").
+        Logger(logger)
-                RuntimePath("./pgdata").
-                BinaryRepositoryURL("https://repo1.maven.org/maven2").
+    postgres := embeddedpostgres.NewDatabase(conf)
-                Port(15432).
+    err := postgres.Start()
-                StartTimeout(15 * time.Second).
+    if err != nil {
-                Logger(logger)
+        fmt.Println(err)
-        postgres := embeddedpostgres.NewDatabase(conf)
+    err = postgres.Stop()
-        err := postgres.Start()
+    if err != nil {
-                if err != nil {
+        fmt.Println(err)
-                        fmt.Println(err)
-−
+}
-         err = postgres.Stop()
+func killPort(port int64) {
-                 if err != nil {
+    // defer wg.Done()
-                        fmt.Println(err)
+    d := GOnetstat.Tcp()
+    for _, p := range d {
+}
 ```