add tableName

Author: DeyiXu

example/main.go

@@ -0,0 +1,92 @@
+package main
+
+import (
+	"context"
+	"fmt"
+	"log"
+
+	"github.com/nilorg/eventbus"
+	"github.com/nilorg/outbox"
+	"github.com/streadway/amqp"
+	"gorm.io/driver/mysql"
+	"gorm.io/gorm"
+	"gorm.io/gorm/schema"
+)
+
+var (
+	db     *gorm.DB
+	bus    eventbus.EventBus
+	engine outbox.Engine
+)
+
+func init() {
+	var (
+		err  error
+		conn *amqp.Connection
+	)
+	conn, err = amqp.Dial("amqp://root:test123@localhost:5672/")
+	if err != nil {
+		panic(err)
+	}
+	bus, err = eventbus.NewRabbitMQ(conn)
+	if err != nil {
+		panic(err)
+	}
+	db, err = gorm.Open(
+		mysql.Open("root:test123@tcp(127.0.0.1:3306)/outbox?charset=utf8&parseTime=True&loc=Local"),
+		&gorm.Config{
+			NamingStrategy: schema.NamingStrategy{
+				SingularTable: true,
+			},
+		},
+	)
+	if err != nil {
+		panic(err)
+	}
+	engine, err = outbox.New(outbox.EngineTypeGorm, db, bus)
+	if err != nil {
+		panic(err)
+	}
+	engine.SubscribeAsync(context.Background(), "user.commit", func(ctx context.Context, msg *outbox.Message) error {
+		fmt.Printf("user.commit: %+v\n", msg)
+		return nil
+	})
+}
+
+func main() {
+	db.AutoMigrate(User{})
+	testUserTran()
+}
+
+func testUserTran() {
+	ctx := context.Background()
+	var (
+		tx  interface{}
+		err error
+	)
+	tx, err = engine.Begin(ctx)
+	if err != nil {
+		log.Printf("tx error: %v", err)
+		return
+	}
+	txDb := tx.(*gorm.DB)
+	err = txDb.Create(&User{
+		Name: "test_name",
+		Age:  11,
+	}).Error
+	if err != nil {
+		engine.Rollback(ctx)
+		return
+	}
+	engine.Commit(ctx, &outbox.CommitMessage{
+		Topic: "user.commit",
+		Value: "提交内容。。。",
+	})
+}
+
+// User ...
+type User struct {
+	gorm.Model
+	Name string
+	Age  int
+}

model.go

@@ -2,6 +2,13 @@ package outbox
 
 import "time"
 
+const (
+	// PublishedTableName ...
+	PublishedTableName = "outbox_published"
+	// ReceivedTableName ...
+	ReceivedTableName = "outbox_received"
+)
+
 // Published ...
 type Published struct {
 	ID         int64      `json:"id" gorm:"column:id;primaryKey;type:BIGINT(20)"`
@@ -16,7 +23,7 @@ type Published struct {
 
 // TableName ...
 func (Published) TableName() string {
-	return "published"
+	return PublishedTableName
 }
 
 // Received ...
@@ -34,5 +41,5 @@ type Received struct {
 
 // TableName ...
 func (Received) TableName() string {
-	return "received"
+	return ReceivedTableName
 }