add connect

This commit is contained in:
2026-06-17 00:22:17 +07:00
parent a61455a538
commit e7112c8b4f
2 changed files with 24 additions and 5 deletions
+2
View File
@@ -7,6 +7,8 @@
```shell ```shell
make generate make generate
go mod tidy go mod tidy
docker compose -f docker-compose-db.yml up -d
cp .env.example .env
``` ```
Запуск Запуск
+22 -5
View File
@@ -1,18 +1,35 @@
package main package main
import ( import (
"${REPO_NAME_SNAKE}/internal/app"
proto "${REPO_NAME_SNAKE}/proto"
"context" "context"
"github.com/grpc-ecosystem/grpc-gateway/v2/runtime"
"google.golang.org/grpc"
"google.golang.org/grpc/credentials/insecure"
"log" "log"
"net" "net"
"net/http" "net/http"
"os"
"${REPO_NAME_SNAKE}/internal/app"
proto "${REPO_NAME_SNAKE}/proto"
"github.com/grpc-ecosystem/grpc-gateway/v2/runtime"
"github.com/jackc/pgx/v5/pgxpool"
"github.com/joho/godotenv"
"google.golang.org/grpc"
"google.golang.org/grpc/credentials/insecure"
) )
func main() { func main() {
_ = godotenv.Load()
dbpool, err := pgxpool.New(context.Background(), os.Getenv("DATABASE_URL"))
if err != nil {
log.Fatalf("Unable to create connection pool: %v\n", err)
}
defer dbpool.Close()
var greeting string
if err = dbpool.QueryRow(context.Background(), "select 'Hello, world!'").Scan(&greeting); err != nil {
log.Fatalf("QueryRow failed: %v\n", err)
}
// Create a listener on TCP port // Create a listener on TCP port
lis, err := net.Listen("tcp", ":8080") lis, err := net.Listen("tcp", ":8080")
if err != nil { if err != nil {