Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package main
- import (
- "database/sql"
- "fmt"
- "github.com/aws/aws-sdk-go/aws/session"
- "github.com/aws/aws-sdk-go/service/rds/rdsutils"
- _ "github.com/lib/pq" // here
- "log"
- )
- const (
- awsBucketRegion = "eu-west-3c"
- awsEndpoint = "testingsportable.c5oslprpblsm.eu-west-3.rds.amazonaws.com"
- awsDbUser = "postgres"
- awsDbName = "postgres"
- )
- func main() {
- mySession := session.Must(session.NewSession())
- authToken, err := rdsutils.BuildAuthToken(awsEndpoint, awsBucketRegion, awsDbUser, mySession.Config.Credentials)
- if err!= nil {
- log.Fatal(err)
- }
- dnsStr := fmt.Sprintf("%s:%s@tcp(%s)/%s?tls=true",
- awsDbUser, authToken, awsEndpoint, awsDbName,
- )
- // Use db to perform SQL operations on database
- db, err := sql.Open("postgres", dnsStr)
- _,err=db.Query("CREATE TABLE Persons2 ( PersonID int, LastName varchar(255));")
- if err != nil {
- log.Fatal(err)
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement