ppgorm

ppgorm

This package instruments the go-gorm/gorm package.

Installation

$ go get github.com/pinpoint-apm/pinpoint-go-agent/plugin/gorm

import "github.com/pinpoint-apm/pinpoint-go-agent/plugin/gorm"

Usage

This package instruments the go-gorm/gorm calls. Use the Open as the gorm.Open.

g, err := ppgorm.Open(mysql.New(mysql.Config{Conn: db}), &gorm.Config{})

It is necessary to pass the context containing the pinpoint.Tracer to gorm.DB.

g = g.WithContext(pinpoint.NewContext(context.Background(), tracer))
g.Create(&Product{Code: "D42", Price: 100})

package main

import (
    "github.com/pinpoint-apm/pinpoint-go-agent"
    "github.com/pinpoint-apm/pinpoint-go-agent/plugin/gorm"
    _ "github.com/pinpoint-apm/pinpoint-go-agent/plugin/mysql"
    "gorm.io/driver/mysql"
    "gorm.io/gorm"
)

func gormQuery(w http.ResponseWriter, r *http.Request) {
    db, err := sql.Open("mysql-pinpoint", "root:p123@tcp(127.0.0.1:3306)/testdb")
    gormdb, err := ppgorm.Open(mysql.New(mysql.Config{Conn: db}), &gorm.Config{})
    gormdb = gormdb.WithContext(r.Context())

    gormdb.AutoMigrate(&Product{})
    gormdb.Create(&Product{Code: "D42", Price: 100})

    var product Product
    gormdb.First(&product, "code = ?", "D42")

    ...
}

Full Example Source