feat:改回dtm

Author: 卖女孩的小火柴

src/ConfigProvider.php

@@ -11,8 +11,8 @@
 use DtmClient\Api\ApiInterface;
 use DtmClient\Api\HttpApi;
 use DtmClient\Api\HttpApiFactory;
+use DtmClient\DBSpecial\DBSpecialFactory;
 use DtmClient\DBSpecial\DBSpecialInterface;
-use DtmClient\DBSpecial\MySqlDBSpecial;
 use DtmClient\DbTransaction\DBTransactionInterface;
 use DtmClient\DbTransaction\HyperfDbTransaction;
 use DtmClient\Grpc\GrpcClientManager;
@@ -43,7 +43,7 @@ public function __invoke(): array
                 ApiInterface::class => ApiFactory::class,
                 GrpcClientManager::class => GrpcClientManagerFactory::class,
                 DBTransactionInterface::class => HyperfDbTransaction::class,
-                DBSpecialInterface::class => MySqlDBSpecial::class,
+                DBSpecialInterface::class => DBSpecialFactory::class,
                 PathGeneratorInterface::class => DtmPatchGenerator::class,
                 JsonRpcTransporter::class => JsonRpcPoolTransporter::class,
                 ResponseInterface::class => Response::class,

src/DBSpecial/DBSpecialFactory.php

@@ -0,0 +1,33 @@
+<?php
+
+declare(strict_types=1);
+/**
+ * This file is part of DTM-PHP.
+ *
+ * @license  https://github.com/dtm-php/dtm-client/blob/master/LICENSE
+ */
+namespace DtmClient\DBSpecial;
+
+use DtmClient\Constants\DbType;
+use DtmClient\Exception\UnsupportedException;
+use Hyperf\Contract\ConfigInterface;
+use Psr\Container\ContainerExceptionInterface;
+use Psr\Container\ContainerInterface;
+use Psr\Container\NotFoundExceptionInterface;
+
+class DBSpecialFactory
+{
+    /**
+     * @throws UnsupportedException
+     * @throws NotFoundExceptionInterface
+     * @throws ContainerExceptionInterface
+     */
+    public function __invoke(ContainerInterface $container): DBSpecialInterface
+    {
+        $type = $container->get(ConfigInterface::class)->get('dtm.barrier.db.type', DbType::MySQL);
+        return match ($type) {
+            DbType::MySQL => $container->get(MySqlDBSpecial::class),
+            default => throw new UnsupportedException(),
+        };
+    }
+}

src/XA.php

@@ -17,7 +17,6 @@
 use DtmClient\Exception\InvalidArgumentException;
 use DtmClient\Exception\UnsupportedException;
 use DtmClient\Exception\XaTransactionException;
-use DtmClient\Grpc\Message\DtmBranchRequest;
 use Google\Protobuf\Internal\Message;
 
 class XA extends AbstractTransaction