diff --git a/test/xa_test.go b/test/xa_test.go
new file mode 100644
index 0000000..35ac8ee
--- /dev/null
+++ b/test/xa_test.go
@@ -0,0 +1,61 @@
+package test
+
+import (
+	"fmt"
+	"testing"
+
+	"github.com/go-resty/resty/v2"
+	"github.com/stretchr/testify/assert"
+	"github.com/yedf/dtm/dtmcli"
+	"github.com/yedf/dtm/examples"
+)
+
+func TestXa(t *testing.T) {
+	if config.DB["driver"] != "mysql" {
+		return
+	}
+	xaLocalError(t)
+	xaNormal(t)
+	xaRollback(t)
+}
+
+func xaLocalError(t *testing.T) {
+	xc := examples.XaClient
+	err := xc.XaGlobalTransaction("xaLocalError", func(xa *dtmcli.Xa) (*resty.Response, error) {
+		return nil, fmt.Errorf("an error")
+	})
+	assert.Error(t, err, fmt.Errorf("an error"))
+}
+
+func xaNormal(t *testing.T) {
+	xc := examples.XaClient
+	gid := "xaNormal"
+	err := xc.XaGlobalTransaction(gid, func(xa *dtmcli.Xa) (*resty.Response, error) {
+		req := examples.GenTransReq(30, false, false)
+		resp, err := xa.CallBranch(req, examples.Busi+"/TransOutXa")
+		if err != nil {
+			return resp, err
+		}
+		return xa.CallBranch(req, examples.Busi+"/TransInXa")
+	})
+	assert.Equal(t, nil, err)
+	WaitTransProcessed(gid)
+	assert.Equal(t, []string{"prepared", "succeed", "prepared", "succeed"}, getBranchesStatus(gid))
+}
+
+func xaRollback(t *testing.T) {
+	xc := examples.XaClient
+	gid := "xaRollback"
+	err := xc.XaGlobalTransaction(gid, func(xa *dtmcli.Xa) (*resty.Response, error) {
+		req := &examples.TransReq{Amount: 30, TransInResult: "FAILURE"}
+		resp, err := xa.CallBranch(req, examples.Busi+"/TransOutXa")
+		if err != nil {
+			return resp, err
+		}
+		return xa.CallBranch(req, examples.Busi+"/TransInXa")
+	})
+	assert.Error(t, err)
+	WaitTransProcessed(gid)
+	assert.Equal(t, []string{"succeed", "prepared"}, getBranchesStatus(gid))
+	assert.Equal(t, "failed", getTransStatus(gid))
+}