- update mod

- update vendor
- redis增加url连接
33 changed files with 906 additions and 168 deletions
--- a/.gitignore
+++ b/.gitignore
@ -7,5 +7,5 @@
 *_test.go
 *.txt
 *.text
-gomod.sh
+go_mod.sh
 /vendor/
--- a/README.md
+++ b/README.md
@ -1,8 +1,8 @@
 <h1>
-<a href="https://www.dtapp.net/">Golang Dorm</a>
+<a href="https://www.dtapp.net/">Golang</a>
 </h1>

-📦 Golang Dorm
+📦 Golang 数据库

 [comment]: <> (go)
 [![godoc](https://pkg.go.dev/badge/go.dtapp.net/dorm?status.svg)](https://pkg.go.dev/go.dtapp.net/dorm)
@ -13,5 +13,5 @@
 #### 安装

 ```shell
-go get -v -u go.dtapp.net/dorm
+go get -v -u go.dtapp.net/dorm@v1.0.59
 ```
--- a/go.mod
+++ b/go.mod
@ -1,48 +1,57 @@
 module go.dtapp.net/dorm

-go 1.21.5
+go 1.22.1

 require (
-	github.com/basgys/goxml2json v1.1.0
-	github.com/redis/go-redis/v9 v9.3.1
+	github.com/redis/go-redis/v9 v9.5.1
 	github.com/sirupsen/logrus v1.9.3
-	go.dtapp.net/gojson v1.0.2
-	go.dtapp.net/gotime v1.0.6
-	gorm.io/driver/mysql v1.5.2
-	gorm.io/driver/postgres v1.5.4
-	gorm.io/gen v0.3.24
-	gorm.io/gorm v1.25.5
+	go.dtapp.net/gojson v1.0.4
+	go.dtapp.net/gotime v1.0.8
+	go.mongodb.org/mongo-driver v1.15.0
+	gorm.io/driver/mysql v1.5.6
+	gorm.io/driver/postgres v1.5.7
+	gorm.io/gen v0.3.26
+	gorm.io/gorm v1.25.10
 )

 require (
-	github.com/bitly/go-simplejson v0.5.1 // indirect
-	github.com/bytedance/sonic v1.10.2 // indirect
-	github.com/cespare/xxhash/v2 v2.2.0 // indirect
-	github.com/chenzhuoyu/base64x v0.0.0-20230717121745-296ad89f973d // indirect
-	github.com/chenzhuoyu/iasm v0.9.1 // indirect
+	filippo.io/edwards25519 v1.1.0 // indirect
+	github.com/basgys/goxml2json v1.1.0 // indirect
+	github.com/bytedance/sonic v1.11.6 // indirect
+	github.com/bytedance/sonic/loader v0.1.1 // indirect
+	github.com/cespare/xxhash/v2 v2.3.0 // indirect
+	github.com/cloudwego/base64x v0.1.4 // indirect
+	github.com/cloudwego/iasm v0.2.0 // indirect
 	github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f // indirect
-	github.com/go-sql-driver/mysql v1.7.1 // indirect
+	github.com/go-sql-driver/mysql v1.8.1 // indirect
 	github.com/goccy/go-json v0.10.2 // indirect
+	github.com/golang/snappy v0.0.4 // indirect
 	github.com/jackc/pgpassfile v1.0.0 // indirect
 	github.com/jackc/pgservicefile v0.0.0-20231201235250-de7065d80cb9 // indirect
-	github.com/jackc/pgx/v5 v5.5.1 // indirect
+	github.com/jackc/pgx/v5 v5.5.5 // indirect
 	github.com/jackc/puddle/v2 v2.2.1 // indirect
 	github.com/jinzhu/inflection v1.0.0 // indirect
 	github.com/jinzhu/now v1.1.5 // indirect
 	github.com/json-iterator/go v1.1.12 // indirect
-	github.com/klauspost/cpuid/v2 v2.2.6 // indirect
+	github.com/klauspost/compress v1.17.8 // indirect
+	github.com/klauspost/cpuid/v2 v2.2.7 // indirect
 	github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect
 	github.com/modern-go/reflect2 v1.0.2 // indirect
+	github.com/montanaflynn/stats v0.7.1 // indirect
 	github.com/twitchyliquid64/golang-asm v0.15.1 // indirect
-	golang.org/x/arch v0.6.0 // indirect
-	golang.org/x/crypto v0.17.0 // indirect
-	golang.org/x/mod v0.14.0 // indirect
-	golang.org/x/net v0.19.0 // indirect
-	golang.org/x/sync v0.5.0 // indirect
-	golang.org/x/sys v0.15.0 // indirect
+	github.com/xdg-go/pbkdf2 v1.0.0 // indirect
+	github.com/xdg-go/scram v1.1.2 // indirect
+	github.com/xdg-go/stringprep v1.0.4 // indirect
+	github.com/youmark/pkcs8 v0.0.0-20240424034433-3c2c7870ae76 // indirect
+	golang.org/x/arch v0.7.0 // indirect
+	golang.org/x/crypto v0.22.0 // indirect
+	golang.org/x/mod v0.17.0 // indirect
+	golang.org/x/net v0.24.0 // indirect
+	golang.org/x/sync v0.7.0 // indirect
+	golang.org/x/sys v0.19.0 // indirect
 	golang.org/x/text v0.14.0 // indirect
-	golang.org/x/tools v0.16.1 // indirect
+	golang.org/x/tools v0.20.0 // indirect
 	gorm.io/datatypes v1.2.0 // indirect
 	gorm.io/hints v1.1.2 // indirect
-	gorm.io/plugin/dbresolver v1.5.0 // indirect
+	gorm.io/plugin/dbresolver v1.5.1 // indirect
 )
--- a/go.sum
+++ b/go.sum
@ -1,3 +1,5 @@
+filippo.io/edwards25519 v1.1.0 h1:FNf4tywRC1HmFuKW5xopWpigGjJKiJSV0Cqo0cJWDaA=
+filippo.io/edwards25519 v1.1.0/go.mod h1:BxyFTGdWcka3PhytdK4V28tE5sGfRvvvRV7EaN4VDT4=
 github.com/basgys/goxml2json v1.1.0 h1:4ln5i4rseYfXNd86lGEB+Vi652IsIXIvggKM/BhUKVw=
 github.com/basgys/goxml2json v1.1.0/go.mod h1:wH7a5Np/Q4QoECFIU8zTQlZwZkrilY0itPfecMw41Dw=
 github.com/bitly/go-simplejson v0.5.1 h1:xgwPbetQScXt1gh9BmoJ6j9JMr3TElvuIyjR8pgdoow=
@ -6,19 +8,16 @@ github.com/bsm/ginkgo/v2 v2.12.0 h1:Ny8MWAHyOepLGlLKYmXG4IEkioBysk6GpaRTLC8zwWs=
 github.com/bsm/ginkgo/v2 v2.12.0/go.mod h1:SwYbGRRDovPVboqFv0tPTcG1sN61LM1Z4ARdbAV9g4c=
 github.com/bsm/gomega v1.27.10 h1:yeMWxP2pV2fG3FgAODIY8EiRE3dy0aeFYt4l7wh6yKA=
 github.com/bsm/gomega v1.27.10/go.mod h1:JyEr/xRbxbtgWNi8tIEVPUYZ5Dzef52k01W3YH0H+O0=
-github.com/bytedance/sonic v1.5.0/go.mod h1:ED5hyg4y6t3/9Ku1R6dU/4KyJ48DZ4jPhfY1O2AihPM=
-github.com/bytedance/sonic v1.10.0-rc/go.mod h1:ElCzW+ufi8qKqNW0FY314xriJhyJhuoJ3gFZdAHF7NM=
-github.com/bytedance/sonic v1.10.2 h1:GQebETVBxYB7JGWJtLBi07OVzWwt+8dWA00gEVW2ZFE=
-github.com/bytedance/sonic v1.10.2/go.mod h1:iZcSUejdk5aukTND/Eu/ivjQuEL0Cu9/rf50Hi0u/g4=
-github.com/cespare/xxhash/v2 v2.2.0 h1:DC2CZ1Ep5Y4k3ZQ899DldepgrayRUGE6BBZ/cd9Cj44=
-github.com/cespare/xxhash/v2 v2.2.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
-github.com/chenzhuoyu/base64x v0.0.0-20211019084208-fb5309c8db06/go.mod h1:DH46F32mSOjUmXrMHnKwZdA8wcEefY7UVqBKYGjpdQY=
-github.com/chenzhuoyu/base64x v0.0.0-20221115062448-fe3a3abad311/go.mod h1:b583jCggY9gE99b6G5LEC39OIiVsWj+R97kbl5odCEk=
-github.com/chenzhuoyu/base64x v0.0.0-20230717121745-296ad89f973d h1:77cEq6EriyTZ0g/qfRdp61a3Uu/AWrgIq2s0ClJV1g0=
-github.com/chenzhuoyu/base64x v0.0.0-20230717121745-296ad89f973d/go.mod h1:8EPpVsBuRksnlj1mLy4AWzRNQYxauNi62uWcE3to6eA=
-github.com/chenzhuoyu/iasm v0.9.0/go.mod h1:Xjy2NpN3h7aUqeqM+woSuuvxmIe6+DDsiNLIrkAmYog=
-github.com/chenzhuoyu/iasm v0.9.1 h1:tUHQJXo3NhBqw6s33wkGn9SP3bvrWLdlVIJ3hQBL7P0=
-github.com/chenzhuoyu/iasm v0.9.1/go.mod h1:Xjy2NpN3h7aUqeqM+woSuuvxmIe6+DDsiNLIrkAmYog=
+github.com/bytedance/sonic v1.11.6 h1:oUp34TzMlL+OY1OUWxHqsdkgC/Zfc85zGqw9siXjrc0=
+github.com/bytedance/sonic v1.11.6/go.mod h1:LysEHSvpvDySVdC2f87zGWf6CIKJcAvqab1ZaiQtds4=
+github.com/bytedance/sonic/loader v0.1.1 h1:c+e5Pt1k/cy5wMveRDyk2X4B9hF4g7an8N3zCYjJFNM=
+github.com/bytedance/sonic/loader v0.1.1/go.mod h1:ncP89zfokxS5LZrJxl5z0UJcsk4M4yY2JpfqGeCtNLU=
+github.com/cespare/xxhash/v2 v2.3.0 h1:UL815xU9SqsFlibzuggzjXhog7bL6oX9BbNZnL2UFvs=
+github.com/cespare/xxhash/v2 v2.3.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
+github.com/cloudwego/base64x v0.1.4 h1:jwCgWpFanWmN8xoIUHa2rtzmkd5J2plF/dnLS6Xd/0Y=
+github.com/cloudwego/base64x v0.1.4/go.mod h1:0zlkT4Wn5C6NdauXdJRhSKRlJvmclQ1hhJgA0rcu/8w=
+github.com/cloudwego/iasm v0.2.0 h1:1KNIy1I1H9hNNFEEH3DVnI4UujN+1zjpuk6gwHLTssg=
+github.com/cloudwego/iasm v0.2.0/go.mod h1:8rXZaNYT2n95jn+zTI1sDr+IgcD2GVs0nlbbQPiEFhY=
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
@ -26,21 +25,25 @@ github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f h1:lO4WD4F/r
 github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f/go.mod h1:cuUVRXasLTGF7a8hSLbxyZXjz+1KgoB3wDUb6vlszIc=
 github.com/go-sql-driver/mysql v1.6.0/go.mod h1:DCzpHaOWr8IXmIStZouvnhqoel9Qv2LBy8hT2VhHyBg=
 github.com/go-sql-driver/mysql v1.7.0/go.mod h1:OXbVy3sEdcQ2Doequ6Z5BW6fXNQTmx+9S1MCJN5yJMI=
-github.com/go-sql-driver/mysql v1.7.1 h1:lUIinVbN1DY0xBg0eMOzmmtGoHwWBbvnWubQUrtU8EI=
-github.com/go-sql-driver/mysql v1.7.1/go.mod h1:OXbVy3sEdcQ2Doequ6Z5BW6fXNQTmx+9S1MCJN5yJMI=
+github.com/go-sql-driver/mysql v1.8.1 h1:LedoTUt/eveggdHS9qUFC1EFSa8bU2+1pZjSRpvNJ1Y=
+github.com/go-sql-driver/mysql v1.8.1/go.mod h1:wEBSXgmK//2ZFJyE+qWnIsVGmvmEKlqwuVSjsCm7DZg=
 github.com/goccy/go-json v0.10.2 h1:CrxCmQqYDkv1z7lO7Wbh2HN93uovUHgrECaO5ZrCXAU=
 github.com/goccy/go-json v0.10.2/go.mod h1:6MelG93GURQebXPDq3khkgXZkazVtN9CRI+MGFi0w8I=
 github.com/golang-sql/civil v0.0.0-20220223132316-b832511892a9 h1:au07oEsX2xN0ktxqI+Sida1w446QrXBRJ0nee3SNZlA=
 github.com/golang-sql/civil v0.0.0-20220223132316-b832511892a9/go.mod h1:8vg3r2VgvsThLBIFL93Qb5yWzgyZWhEmBwUJWevAkK0=
 github.com/golang-sql/sqlexp v0.1.0 h1:ZCD6MBpcuOVfGVqsEmY5/4FtYiKz6tSyUv9LPEDei6A=
 github.com/golang-sql/sqlexp v0.1.0/go.mod h1:J4ad9Vo8ZCWQ2GMrC4UCQy1JpCbwU9m3EOqtpKwwwHI=
+github.com/golang/snappy v0.0.4 h1:yAGX7huGHXlcLOEtBnF4w7FQwA26wojNCwOYAEhLjQM=
+github.com/golang/snappy v0.0.4/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q=
+github.com/google/go-cmp v0.5.2 h1:X2ev0eStA3AbceY54o37/0PQ/UWqKEiiO2dKL5OPaFM=
+github.com/google/go-cmp v0.5.2/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
 github.com/google/gofuzz v1.0.0/go.mod h1:dBl0BpW6vV/+mYPU4Po3pmUjxk6FQPldtuIdl/M65Eg=
 github.com/jackc/pgpassfile v1.0.0 h1:/6Hmqy13Ss2zCq62VdNG8tM1wchn8zjSGOBJ6icpsIM=
 github.com/jackc/pgpassfile v1.0.0/go.mod h1:CEx0iS5ambNFdcRtxPj5JhEz+xB6uRky5eyVu/W2HEg=
 github.com/jackc/pgservicefile v0.0.0-20231201235250-de7065d80cb9 h1:L0QtFUgDarD7Fpv9jeVMgy/+Ec0mtnmYuImjTz6dtDA=
 github.com/jackc/pgservicefile v0.0.0-20231201235250-de7065d80cb9/go.mod h1:5TJZWKEWniPve33vlWYSoGYefn3gLQRzjfDlhSJ9ZKM=
-github.com/jackc/pgx/v5 v5.5.1 h1:5I9etrGkLrN+2XPCsi6XLlV5DITbSL/xBZdmAxFcXPI=
-github.com/jackc/pgx/v5 v5.5.1/go.mod h1:Ig06C2Vu0t5qXC60W8sqIthScaEnFvojjj9dSljmHRA=
+github.com/jackc/pgx/v5 v5.5.5 h1:amBjrZVmksIdNjxGW/IiIMzxMKZFelXbUoPNb+8sjQw=
+github.com/jackc/pgx/v5 v5.5.5/go.mod h1:ez9gk+OAat140fv9ErkZDYFWmXLfV+++K0uAOiwgm1A=
 github.com/jackc/puddle/v2 v2.2.1 h1:RhxXJtFG022u4ibrCSMSiu5aOq1i77R3OHKNJj77OAk=
 github.com/jackc/puddle/v2 v2.2.1/go.mod h1:vriiEXHvEE654aYKXXjOvZM39qJ0q+azkZFrfEOc3H4=
 github.com/jinzhu/inflection v1.0.0 h1:K317FqzuhWc8YvSVlFMCCUb36O/S9MCKRDI7QkRKD/E=
@ -50,9 +53,11 @@ github.com/jinzhu/now v1.1.5 h1:/o9tlHleP7gOFmsnYNz3RGnqzefHA47wQpKrrdTIwXQ=
 github.com/jinzhu/now v1.1.5/go.mod h1:d3SSVoowX0Lcu0IBviAWJpolVfI5UJVZZ7cO71lE/z8=
 github.com/json-iterator/go v1.1.12 h1:PV8peI4a0ysnczrg+LtxykD8LfKY9ML6u2jnxaEnrnM=
 github.com/json-iterator/go v1.1.12/go.mod h1:e30LSqwooZae/UwlEbR2852Gd8hjQvJoHmT4TnhNGBo=
+github.com/klauspost/compress v1.17.8 h1:YcnTYrq7MikUT7k0Yb5eceMmALQPYBW/Xltxn0NAMnU=
+github.com/klauspost/compress v1.17.8/go.mod h1:Di0epgTjJY877eYKx5yC51cX2A2Vl2ibi7bDH9ttBbw=
 github.com/klauspost/cpuid/v2 v2.0.9/go.mod h1:FInQzS24/EEf25PyTYn52gqo7WaD8xa0213Md/qVLRg=
-github.com/klauspost/cpuid/v2 v2.2.6 h1:ndNyv040zDGIDh8thGkXYjnFtiN02M1PVVF+JE/48xc=
-github.com/klauspost/cpuid/v2 v2.2.6/go.mod h1:Lcz8mBdAVJIBVzewtcLocK12l3Y+JytZYpaMropDUws=
+github.com/klauspost/cpuid/v2 v2.2.7 h1:ZWSB3igEs+d0qvnxR/ZBzXVmxkgt8DdzP6m9pfuVLDM=
+github.com/klauspost/cpuid/v2 v2.2.7/go.mod h1:Lcz8mBdAVJIBVzewtcLocK12l3Y+JytZYpaMropDUws=
 github.com/knz/go-libedit v1.10.1/go.mod h1:MZTVkCWyz0oBc7JOWP3wNAzd002ZbM/5hgShxwh4x8M=
 github.com/mattn/go-sqlite3 v1.14.15/go.mod h1:2eHXhiwb8IkHr+BDWZGa96P6+rkvnG63S2DGjv9HUNg=
 github.com/mattn/go-sqlite3 v1.14.16 h1:yOQRA0RpS5PFz/oikGwBEqvAWhWg5ufRz4ETLjwpU1Y=
@ -64,10 +69,12 @@ github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd h1:TRLaZ9cD/w
 github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q=
 github.com/modern-go/reflect2 v1.0.2 h1:xBagoLtFs94CBntxluKeaWgTMpvLxC4ur3nMaC9Gz0M=
 github.com/modern-go/reflect2 v1.0.2/go.mod h1:yWuevngMOJpCy52FWWMvUC8ws7m/LJsjYzDa0/r8luk=
+github.com/montanaflynn/stats v0.7.1 h1:etflOAAHORrCC44V+aR6Ftzort912ZU+YLiSTuV8eaE=
+github.com/montanaflynn/stats v0.7.1/go.mod h1:etXPPgVO6n31NxCd9KQUMvCM+ve0ruNzt6R8Bnaayow=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
-github.com/redis/go-redis/v9 v9.3.1 h1:KqdY8U+3X6z+iACvumCNxnoluToB+9Me+TvyFa21Mds=
-github.com/redis/go-redis/v9 v9.3.1/go.mod h1:hdY0cQFCN4fnSYT6TkisLufl/4W5UIXyv0b/CLO2V2M=
+github.com/redis/go-redis/v9 v9.5.1 h1:H1X4D3yHPaYrkL5X06Wh6xNVM/pX0Ft4RV0vMGvLBh8=
+github.com/redis/go-redis/v9 v9.5.1/go.mod h1:hdY0cQFCN4fnSYT6TkisLufl/4W5UIXyv0b/CLO2V2M=
 github.com/sirupsen/logrus v1.9.3 h1:dueUQJ1C2q9oE3F7wvmSGAaVtTmUizReu6fjN8uqzbQ=
 github.com/sirupsen/logrus v1.9.3/go.mod h1:naHLuLoDiP4jHNo9R0sCBMtWGeIprob74mVsIT4qYEQ=
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
@ -77,34 +84,69 @@ github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UV
 github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
 github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
 github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO+kdMU+MU=
+github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKsk=
 github.com/stretchr/testify v1.8.1/go.mod h1:w2LPCIKwWwSfY2zedu0+kehJoqGctiVI29o6fzry7u4=
-github.com/stretchr/testify v1.8.2 h1:+h33VjcLVPDHtOdpUCuF+7gSuG3yGIftsP1YvFihtJ8=
-github.com/stretchr/testify v1.8.2/go.mod h1:w2LPCIKwWwSfY2zedu0+kehJoqGctiVI29o6fzry7u4=
 github.com/twitchyliquid64/golang-asm v0.15.1 h1:SU5vSMR7hnwNxj24w34ZyCi/FmDZTkS4MhqMhdFk5YI=
 github.com/twitchyliquid64/golang-asm v0.15.1/go.mod h1:a1lVb/DtPvCB8fslRZhAngC2+aY1QWCk3Cedj/Gdt08=
-go.dtapp.net/gojson v1.0.2 h1:NjslBOhAK3XvJepkML7LXcJRPtSfp3rDXGK/29VlDBw=
-go.dtapp.net/gojson v1.0.2/go.mod h1:U0Vd2iSLKqdyg6oungBJVHxuYswTbeQVjruQC3/JqQ4=
-go.dtapp.net/gotime v1.0.6 h1:f8YowUxpZtJbYawe5s5PmvGxRj61ydlzxAPYr5Fcetg=
-go.dtapp.net/gotime v1.0.6/go.mod h1:Gq7eNLr2iMLP18UNWONRq4V3Uhf/ADp4bIrS+Tc6ktY=
+github.com/xdg-go/pbkdf2 v1.0.0 h1:Su7DPu48wXMwC3bs7MCNG+z4FhcyEuz5dlvchbq0B0c=
+github.com/xdg-go/pbkdf2 v1.0.0/go.mod h1:jrpuAogTd400dnrH08LKmI/xc1MbPOebTwRqcT5RDeI=
+github.com/xdg-go/scram v1.1.2 h1:FHX5I5B4i4hKRVRBCFRxq1iQRej7WO3hhBuJf+UUySY=
+github.com/xdg-go/scram v1.1.2/go.mod h1:RT/sEzTbU5y00aCK8UOx6R7YryM0iF1N2MOmC3kKLN4=
+github.com/xdg-go/stringprep v1.0.4 h1:XLI/Ng3O1Atzq0oBs3TWm+5ZVgkq2aqdlvP9JtoZ6c8=
+github.com/xdg-go/stringprep v1.0.4/go.mod h1:mPGuuIYwz7CmR2bT9j4GbQqutWS1zV24gijq1dTyGkM=
+github.com/youmark/pkcs8 v0.0.0-20240424034433-3c2c7870ae76 h1:tBiBTKHnIjovYoLX/TPkcf+OjqqKGQrPtGT3Foz+Pgo=
+github.com/youmark/pkcs8 v0.0.0-20240424034433-3c2c7870ae76/go.mod h1:SQliXeA7Dhkt//vS29v3zpbEwoa+zb2Cn5xj5uO4K5U=
+github.com/yuin/goldmark v1.4.13/go.mod h1:6yULJ656Px+3vBD8DxQVa3kxgyrAnzto9xy5taEt/CY=
+go.dtapp.net/gojson v1.0.4 h1:9en9iyOOLWoEIo2eKhqt3/Djh/3HhwsTpXxgI9efPRo=
+go.dtapp.net/gojson v1.0.4/go.mod h1:G9CMVzNSRkbNzIic/vJqHCOyKtw6BW2YM8Vyn64zfM0=
+go.dtapp.net/gotime v1.0.8 h1:ngKBp7j3Ime1t2jU94gUeshPX1StV5E2x4STlzDMmLU=
+go.dtapp.net/gotime v1.0.8/go.mod h1:BQT911XSfaJDBYPiEKGFwMjvgnZtx1F3nWu4GTg5ISY=
+go.mongodb.org/mongo-driver v1.15.0 h1:rJCKC8eEliewXjZGf0ddURtl7tTVy1TK3bfl0gkUSLc=
+go.mongodb.org/mongo-driver v1.15.0/go.mod h1:Vzb0Mk/pa7e6cWw85R4F/endUC3u0U9jGcNU603k65c=
 golang.org/x/arch v0.0.0-20210923205945-b76863e36670/go.mod h1:5om86z9Hs0C8fWVUuoMHwpExlXzs5Tkyp9hOrfG7pp8=
-golang.org/x/arch v0.6.0 h1:S0JTfE48HbRj80+4tbvZDYsJ3tGv6BUU3XxyZ7CirAc=
-golang.org/x/arch v0.6.0/go.mod h1:FEVrYAQjsQXMVJ1nsMoVVXPZg6p2JE2mx8psSWTDQys=
-golang.org/x/crypto v0.17.0 h1:r8bRNjWL3GshPW3gkd+RpvzWrZAwPS49OmTGZ/uhM4k=
-golang.org/x/crypto v0.17.0/go.mod h1:gCAAfMLgwOJRpTjQ2zCCt2OcSfYMTeZVSRtQlPC7Nq4=
-golang.org/x/mod v0.14.0 h1:dGoOF9QVLYng8IHTm7BAyWqCqSheQ5pYWGhzW00YJr0=
-golang.org/x/mod v0.14.0/go.mod h1:hTbmBsO62+eylJbnUtE2MGJUyE7QWk4xUqPFrRgJ+7c=
-golang.org/x/net v0.19.0 h1:zTwKpTd2XuCqf8huc7Fo2iSy+4RHPd10s4KzeTnVr1c=
-golang.org/x/net v0.19.0/go.mod h1:CfAk/cbD4CthTvqiEl8NpboMuiuOYsAr/7NOjZJtv1U=
-golang.org/x/sync v0.5.0 h1:60k92dhOjHxJkrqnwsfl8KuaHbn/5dl0lUPUklKo3qE=
-golang.org/x/sync v0.5.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk=
+golang.org/x/arch v0.7.0 h1:pskyeJh/3AmoQ8CPE95vxHLqp1G1GfGNXTmcl9NEKTc=
+golang.org/x/arch v0.7.0/go.mod h1:FEVrYAQjsQXMVJ1nsMoVVXPZg6p2JE2mx8psSWTDQys=
+golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
+golang.org/x/crypto v0.0.0-20210921155107-089bfa567519/go.mod h1:GvvjBRRGRdwPK5ydBHafDWAxML/pGHZbMvKqRZ5+Abc=
+golang.org/x/crypto v0.22.0 h1:g1v0xeRhjcugydODzvb3mEM9SQ0HGp9s/nh3COQ/C30=
+golang.org/x/crypto v0.22.0/go.mod h1:vr6Su+7cTlO45qkww3VDJlzDn0ctJvRgYbC2NvXHt+M=
+golang.org/x/mod v0.6.0-dev.0.20220419223038-86c51ed26bb4/go.mod h1:jJ57K6gSWd91VN4djpZkiMVwK6gcyfeH4XE8wZrZaV4=
+golang.org/x/mod v0.17.0 h1:zY54UmvipHiNd+pm+m0x9KhZ9hl1/7QNMyxXbc6ICqA=
+golang.org/x/mod v0.17.0/go.mod h1:hTbmBsO62+eylJbnUtE2MGJUyE7QWk4xUqPFrRgJ+7c=
+golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
+golang.org/x/net v0.0.0-20210226172049-e18ecbb05110/go.mod h1:m0MpNAwzfU5UDzcl9v0D8zg8gWTRqZa9RBIspLL5mdg=
+golang.org/x/net v0.0.0-20220722155237-a158d28d115b/go.mod h1:XRhObCWvk6IyKnWLug+ECip1KBveYUHfp+8e9klMJ9c=
+golang.org/x/net v0.24.0 h1:1PcaxkF854Fu3+lvBIx5SYn9wRlBzzcnHZSiaFFAb0w=
+golang.org/x/net v0.24.0/go.mod h1:2Q7sJY5mzlzWjKtYUEXSlBWCdyaioyXzRB2RtU8KVE8=
+golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
+golang.org/x/sync v0.0.0-20220722155255-886fb9371eb4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
+golang.org/x/sync v0.7.0 h1:YsImfSBoP9QPYL0xyKJPq0gcaJdG3rInoqxTWbfQu9M=
+golang.org/x/sync v0.7.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk=
+golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
+golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20210615035016-665e8c7367d1/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.0.0-20220520151302-bc2c85ada10a/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.0.0-20220715151400-c0bba94af5f8/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.0.0-20220722155257-8c9f86f7a55f/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.5.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
-golang.org/x/sys v0.15.0 h1:h48lPFYpsTvQJZF4EKyI4aLHaev3CxivZmv7yZig9pc=
-golang.org/x/sys v0.15.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
+golang.org/x/sys v0.19.0 h1:q5f1RH2jigJ1MoAWp2KTp3gm5zAGFUTarQZ5U386+4o=
+golang.org/x/sys v0.19.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
+golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo=
+golang.org/x/term v0.0.0-20210927222741-03fcf44c2211/go.mod h1:jbD1KX2456YbFQfuXm/mYQcufACuNUgVhRMnK/tPxf8=
+golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
+golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
+golang.org/x/text v0.3.7/go.mod h1:u+2+/6zg+i71rQMx5EYifcz6MCKuco9NR6JIITiCfzQ=
+golang.org/x/text v0.3.8/go.mod h1:E6s5w1FMmriuDzIBO73fBruAKo1PCIq6d2Q6DHfQ8WQ=
 golang.org/x/text v0.14.0 h1:ScX5w1eTa3QqT8oi6+ziP7dTV1S2+ALU0bI+0zXKWiQ=
 golang.org/x/text v0.14.0/go.mod h1:18ZOQIKpY8NJVqYksKHtTdi31H5itFRjB5/qKTNYzSU=
-golang.org/x/tools v0.16.1 h1:TLyB3WofjdOEepBHAU20JdNC1Zbg87elYofWYAY5oZA=
-golang.org/x/tools v0.16.1/go.mod h1:kYVVN6I1mBNoB1OX+noeBjbRk4IUEPa7JJ+TJMEooJ0=
+golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
+golang.org/x/tools v0.0.0-20191119224855-298f0cb1881e/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
+golang.org/x/tools v0.1.12/go.mod h1:hNGJHUnrk76NpqgfD5Aqm5Crs+Hm0VOH/i9J2+nxYbc=
+golang.org/x/tools v0.20.0 h1:hz/CVckiOxybQvFw6h7b/q80NTr9IUQb4s1IIzW7KNY=
+golang.org/x/tools v0.20.0/go.mod h1:WvitBU7JJf6A4jOdg4S1tviW9bhUxkgeCui/0JHctQg=
+golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
+golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543 h1:E7g+9GITq07hpfrRu66IVDexMakfv52eLZ2CXBWiKr4=
+golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
 gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
 gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
@ -112,26 +154,26 @@ gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
 gorm.io/datatypes v1.2.0 h1:5YT+eokWdIxhJgWHdrb2zYUimyk0+TaFth+7a0ybzco=
 gorm.io/datatypes v1.2.0/go.mod h1:o1dh0ZvjIjhH/bngTpypG6lVRJ5chTBxE09FH/71k04=
 gorm.io/driver/mysql v1.4.3/go.mod h1:sSIebwZAVPiT+27jK9HIwvsqOGKx3YMPmrA3mBJR10c=
-gorm.io/driver/mysql v1.5.2 h1:QC2HRskSE75wBuOxe0+iCkyJZ+RqpudsQtqkp+IMuXs=
-gorm.io/driver/mysql v1.5.2/go.mod h1:pQLhh1Ut/WUAySdTHwBpBv6+JKcj+ua4ZFx1QQTBzb8=
-gorm.io/driver/postgres v1.5.4 h1:Iyrp9Meh3GmbSuyIAGyjkN+n9K+GHX9b9MqsTL4EJCo=
-gorm.io/driver/postgres v1.5.4/go.mod h1:Bgo89+h0CRcdA33Y6frlaHHVuTdOf87pmyzwW9C/BH0=
+gorm.io/driver/mysql v1.5.6 h1:Ld4mkIickM+EliaQZQx3uOJDJHtrd70MxAUqWqlx3Y8=
+gorm.io/driver/mysql v1.5.6/go.mod h1:sEtPWMiqiN1N1cMXoXmBbd8C6/l+TESwriotuRRpkDM=
+gorm.io/driver/postgres v1.5.7 h1:8ptbNJTDbEmhdr62uReG5BGkdQyeasu/FZHxI0IMGnM=
+gorm.io/driver/postgres v1.5.7/go.mod h1:3e019WlBaYI5o5LIdNV+LyxCMNtLOQETBXL2h4chKpA=
 gorm.io/driver/sqlite v1.5.0 h1:zKYbzRCpBrT1bNijRnxLDJWPjVfImGEn0lSnUY5gZ+c=
 gorm.io/driver/sqlite v1.5.0/go.mod h1:kDMDfntV9u/vuMmz8APHtHF0b4nyBB7sfCieC6G8k8I=
 gorm.io/driver/sqlserver v1.4.1 h1:t4r4r6Jam5E6ejqP7N82qAJIJAht27EGT41HyPfXRw0=
 gorm.io/driver/sqlserver v1.4.1/go.mod h1:DJ4P+MeZbc5rvY58PnmN1Lnyvb5gw5NPzGshHDnJLig=
-gorm.io/gen v0.3.24 h1:yL1RrCySwTWTQpkUkt2FCe42Xub2eaZP2tM5EQoFBNU=
-gorm.io/gen v0.3.24/go.mod h1:G9uxGfkfNFxPoOrV5P6KQxRMgZsQSCyp9vJP8xiKTGg=
+gorm.io/gen v0.3.26 h1:sFf1j7vNStimPRRAtH4zz5NiHM+1dr6eA9aaRdplyhY=
+gorm.io/gen v0.3.26/go.mod h1:a5lq5y3w4g5LMxBcw0wnO6tYUCdNutWODq5LrIt75LE=
 gorm.io/gorm v1.23.8/go.mod h1:l2lP/RyAtc1ynaTjFksBde/O8v9oOGIApu2/xRitmZk=
 gorm.io/gorm v1.24.7-0.20230306060331-85eaf9eeda11/go.mod h1:L4uxeKpfBml98NYqVqwAdmV1a2nBtAec/cf3fpucW/k=
 gorm.io/gorm v1.25.0/go.mod h1:L4uxeKpfBml98NYqVqwAdmV1a2nBtAec/cf3fpucW/k=
-gorm.io/gorm v1.25.2-0.20230530020048-26663ab9bf55/go.mod h1:L4uxeKpfBml98NYqVqwAdmV1a2nBtAec/cf3fpucW/k=
 gorm.io/gorm v1.25.2/go.mod h1:L4uxeKpfBml98NYqVqwAdmV1a2nBtAec/cf3fpucW/k=
-gorm.io/gorm v1.25.5 h1:zR9lOiiYf09VNh5Q1gphfyia1JpiClIWG9hQaxB/mls=
-gorm.io/gorm v1.25.5/go.mod h1:hbnx/Oo0ChWMn1BIhpy1oYozzpM15i4YPuHDmfYtwg8=
+gorm.io/gorm v1.25.7/go.mod h1:hbnx/Oo0ChWMn1BIhpy1oYozzpM15i4YPuHDmfYtwg8=
+gorm.io/gorm v1.25.10 h1:dQpO+33KalOA+aFYGlK+EfxcI5MbO7EP2yYygwh9h+s=
+gorm.io/gorm v1.25.10/go.mod h1:hbnx/Oo0ChWMn1BIhpy1oYozzpM15i4YPuHDmfYtwg8=
 gorm.io/hints v1.1.2 h1:b5j0kwk5p4+3BtDtYqqfY+ATSxjj+6ptPgVveuynn9o=
 gorm.io/hints v1.1.2/go.mod h1:/ARdpUHAtyEMCh5NNi3tI7FsGh+Cj/MIUlvNxCNCFWg=
-gorm.io/plugin/dbresolver v1.5.0 h1:XVHLxh775eP0CqVh3vcfJtYqja3uFl5Wr3cKlY8jgDY=
-gorm.io/plugin/dbresolver v1.5.0/go.mod h1:l4Cn87EHLEYuqUncpEeTC2tTJQkjngPSD+lo8hIvcT0=
+gorm.io/plugin/dbresolver v1.5.1 h1:s9Dj9f7r+1rE3nx/Ywzc85nXptUEaeOO0pt27xdopM8=
+gorm.io/plugin/dbresolver v1.5.1/go.mod h1:l4Cn87EHLEYuqUncpEeTC2tTJQkjngPSD+lo8hIvcT0=
 nullprogram.com/x/optparse v1.0.0/go.mod h1:KdyPE+Igbe0jQUrVfMqDMeJQIJZEuyV7pjYmp6pbG50=
 rsc.io/pdf v0.1.1/go.mod h1:n8OzWcQ6Sp37PL01nO98y4iUCRdTGarVfzxY20ICaU4=
--- a/goem_sql.go
+++ b/goem_sql.go
@ -0,0 +1,18 @@
+package dorm
+
+import "database/sql"
+
+// Ping ping
+func (c *GormClient) Ping() error {
+	return c.sqlDd.Ping()
+}
+
+// Close 关闭
+func (c *GormClient) Close() error {
+	return c.sqlDd.Close()
+}
+
+// Stats 返回数据库统计信息
+func (c *GormClient) Stats() sql.DBStats {
+	return c.sqlDd.Stats()
+}
--- a/gorm.go
+++ b/gorm.go
@ -1,6 +1,7 @@
 package dorm

 import (
+	"database/sql"
 	"fmt"
 	"github.com/sirupsen/logrus"
 	"gorm.io/gorm"
@ -12,10 +13,12 @@ import (
 // GormClientFun *GormClient 驱动
 type GormClientFun func() *GormClient

-// GormClientTableFun *GormClient 驱动
+// GormClientTableFun
+// *GormClient 驱动
 // string 表名
 type GormClientTableFun func() (*GormClient, string)

+// GormClientConfig 配置
 type GormClientConfig struct {
 	Dns                    string // 地址
 	LogStatus              bool   // 日志 - 状态
@ -32,19 +35,20 @@ type GormClientConfig struct {
 type GormClient struct {
 	db     *gorm.DB          // 驱动
 	config *GormClientConfig // 配置
+	sqlDd  *sql.DB
 }

 type writer struct{}

 // 日志路径
-var logsUrl = ""
+var logsURL = ""

 func (w writer) Printf(format string, args ...interface{}) {

 	now := time.Now()
 	logFilePath := ""
 	if dir, err := os.Getwd(); err == nil {
-		logFilePath = dir + logsUrl
+		logFilePath = dir + logsURL
 	}
 	if err := os.MkdirAll(logFilePath, 0777); err != nil {
 		fmt.Println(err.Error())
--- a/gorm_gen.go
+++ b/gorm_gen.go
@ -8,10 +8,12 @@ import (
 // GormGenClientFun *GormClient 驱动
 type GormGenClientFun func() *GormGenClient

-// GormGenClientTableFun *GormClient 驱动
+// GormGenClientTableFun
+// *GormClient 驱动
 // string 表名
 type GormGenClientTableFun func() (*GormGenClient, string)

+// GormGenClientConfig 配置
 type GormGenClientConfig struct {
 	Dns    string     // dns地址
 	Db     *gorm.DB   // db驱动
--- a/gorm_gen_mysql.go
+++ b/gorm_gen_mysql.go
@ -7,6 +7,7 @@ import (
 	"gorm.io/gorm"
 )

+// NewGormGenMysqlClient 创建GormGenClient实例 mysql
 func NewGormGenMysqlClient(ctx context.Context, config *GormGenClientConfig) (*GormGenClient, error) {

 	c := &GormGenClient{config: config}
--- a/gorm_gen_postgres.go
+++ b/gorm_gen_postgres.go
@ -7,6 +7,7 @@ import (
 	"gorm.io/gorm"
 )

+// NewGormGenPostgresClient 创建GormGenClient实例 postgres
 func NewGormGenPostgresClient(ctx context.Context, config *GormGenClientConfig) (*GormGenClient, error) {

 	c := &GormGenClient{config: config}
--- a/gorm_gen_postgresql.go
+++ b/gorm_gen_postgresql.go
@ -7,6 +7,7 @@ import (
 	"gorm.io/gorm"
 )

+// NewGormGenPostgresqlClient 创建GormGenClient实例 postgresql
 func NewGormGenPostgresqlClient(ctx context.Context, config *GormGenClientConfig) (*GormGenClient, error) {

 	c := &GormGenClient{config: config}
--- a/gorm_get.go
+++ b/gorm_get.go
@ -1,8 +1,16 @@
 package dorm

-import "gorm.io/gorm"
+import (
+	"database/sql"
+	"gorm.io/gorm"
+)

 // GetDb 获取驱动
 func (c *GormClient) GetDb() *gorm.DB {
 	return c.db
 }
+
+// GetSqlDb 获取驱动
+func (c *GormClient) GetSqlDb() *sql.DB {
+	return c.sqlDd
+}
--- a/gorm_mysql.go
+++ b/gorm_mysql.go
@ -11,6 +11,7 @@ import (
 	"time"
 )

+// NewGormMysqlClient 创建GormClient实例 mysql
 func NewGormMysqlClient(ctx context.Context, config *GormClientConfig) (*GormClient, error) {

 	var err error
@ -18,9 +19,9 @@ func NewGormMysqlClient(ctx context.Context, config *GormClientConfig) (*GormCli

 	// 判断路径
 	if c.config.LogPath == "" {
-		logsUrl = "/logs/mysql"
+		logsURL = "/logs/mysql"
 	} else {
-		logsUrl = c.config.LogPath
+		logsURL = c.config.LogPath
 	}

 	if c.config.LogStatus {
@ -60,30 +61,30 @@ func NewGormMysqlClient(ctx context.Context, config *GormClientConfig) (*GormCli
 		return nil, errors.New(fmt.Sprintf("连接失败：%v", err))
 	}

-	sqlDd, err := c.db.DB()
+	c.sqlDd, err = c.db.DB()
 	if err != nil {
-		return nil, errors.New(fmt.Sprintf("检查连接失败：%v", err))
+		return nil, errors.New(fmt.Sprintf("获取通用数据库对象失败：%v", err))
 	}

 	// 设置空闲连接池中连接的最大数量
 	if c.config.ConnSetMaxIdle == 0 {
-		sqlDd.SetMaxIdleConns(10)
+		c.sqlDd.SetMaxIdleConns(10)
 	} else {
-		sqlDd.SetMaxIdleConns(c.config.ConnSetMaxIdle)
+		c.sqlDd.SetMaxIdleConns(c.config.ConnSetMaxIdle)
 	}

 	// 设置打开数据库连接的最大数量
 	if c.config.ConnSetMaxOpen == 0 {
-		sqlDd.SetMaxOpenConns(100)
+		c.sqlDd.SetMaxOpenConns(100)
 	} else {
-		sqlDd.SetMaxOpenConns(c.config.ConnSetMaxOpen)
+		c.sqlDd.SetMaxOpenConns(c.config.ConnSetMaxOpen)
 	}

 	// 设置了连接可复用的最大时间
 	if c.config.ConnSetConnMaxLifetime == 0 {
-		sqlDd.SetConnMaxLifetime(time.Second * 600)
+		c.sqlDd.SetConnMaxLifetime(time.Second * 600)
 	} else {
-		sqlDd.SetConnMaxLifetime(time.Duration(c.config.ConnSetConnMaxLifetime))
+		c.sqlDd.SetConnMaxLifetime(time.Duration(c.config.ConnSetConnMaxLifetime))
 	}

 	return c, nil
--- a/gorm_postgres.go
+++ b/gorm_postgres.go
@ -11,6 +11,7 @@ import (
 	"time"
 )

+// NewGormPostgresClient 创建GormClient实例 postgres
 func NewGormPostgresClient(ctx context.Context, config *GormClientConfig) (*GormClient, error) {

 	var err error
@ -19,9 +20,9 @@ func NewGormPostgresClient(ctx context.Context, config *GormClientConfig) (*Gorm

 	// 判断路径
 	if c.config.LogPath == "" {
-		logsUrl = "/logs/postgresql"
+		logsURL = "/logs/postgresql"
 	} else {
-		logsUrl = c.config.LogPath
+		logsURL = c.config.LogPath
 	}

 	if c.config.LogStatus {
@ -61,30 +62,30 @@ func NewGormPostgresClient(ctx context.Context, config *GormClientConfig) (*Gorm
 		return nil, errors.New(fmt.Sprintf("连接失败：%v", err))
 	}

-	sqlDd, err := c.db.DB()
+	c.sqlDd, err = c.db.DB()
 	if err != nil {
-		return nil, errors.New(fmt.Sprintf("检查连接失败：%v", err))
+		return nil, errors.New(fmt.Sprintf("获取通用数据库对象失败：%v", err))
 	}

 	// 设置空闲连接池中连接的最大数量
 	if c.config.ConnSetMaxIdle == 0 {
-		sqlDd.SetMaxIdleConns(10)
+		c.sqlDd.SetMaxIdleConns(10)
 	} else {
-		sqlDd.SetMaxIdleConns(c.config.ConnSetMaxIdle)
+		c.sqlDd.SetMaxIdleConns(c.config.ConnSetMaxIdle)
 	}

 	// 设置打开数据库连接的最大数量
 	if c.config.ConnSetMaxOpen == 0 {
-		sqlDd.SetMaxOpenConns(100)
+		c.sqlDd.SetMaxOpenConns(100)
 	} else {
-		sqlDd.SetMaxOpenConns(c.config.ConnSetMaxOpen)
+		c.sqlDd.SetMaxOpenConns(c.config.ConnSetMaxOpen)
 	}

 	// 设置了连接可复用的最大时间
 	if c.config.ConnSetConnMaxLifetime == 0 {
-		sqlDd.SetConnMaxLifetime(time.Hour)
+		c.sqlDd.SetConnMaxLifetime(time.Hour)
 	} else {
-		sqlDd.SetConnMaxLifetime(time.Duration(c.config.ConnSetConnMaxLifetime))
+		c.sqlDd.SetConnMaxLifetime(time.Duration(c.config.ConnSetConnMaxLifetime))
 	}

 	return c, nil
--- a/gorm_postgresql.go
+++ b/gorm_postgresql.go
@ -11,6 +11,7 @@ import (
 	"time"
 )

+// NewGormPostgresqlClient 创建GormClient实例 postgresql
 func NewGormPostgresqlClient(ctx context.Context, config *GormClientConfig) (*GormClient, error) {

 	var err error
@ -19,9 +20,9 @@ func NewGormPostgresqlClient(ctx context.Context, config *GormClientConfig) (*Go

 	// 判断路径
 	if c.config.LogPath == "" {
-		logsUrl = "/logs/postgresql"
+		logsURL = "/logs/postgresql"
 	} else {
-		logsUrl = c.config.LogPath
+		logsURL = c.config.LogPath
 	}

 	if c.config.LogStatus {
@ -61,30 +62,30 @@ func NewGormPostgresqlClient(ctx context.Context, config *GormClientConfig) (*Go
 		return nil, errors.New(fmt.Sprintf("连接失败：%v", err))
 	}

-	sqlDd, err := c.db.DB()
+	c.sqlDd, err = c.db.DB()
 	if err != nil {
-		return nil, errors.New(fmt.Sprintf("检查连接失败：%v", err))
+		return nil, errors.New(fmt.Sprintf("获取通用数据库对象失败：%v", err))
 	}

 	// 设置空闲连接池中连接的最大数量
 	if c.config.ConnSetMaxIdle == 0 {
-		sqlDd.SetMaxIdleConns(10)
+		c.sqlDd.SetMaxIdleConns(10)
 	} else {
-		sqlDd.SetMaxIdleConns(c.config.ConnSetMaxIdle)
+		c.sqlDd.SetMaxIdleConns(c.config.ConnSetMaxIdle)
 	}

 	// 设置打开数据库连接的最大数量
 	if c.config.ConnSetMaxOpen == 0 {
-		sqlDd.SetMaxOpenConns(100)
+		c.sqlDd.SetMaxOpenConns(100)
 	} else {
-		sqlDd.SetMaxOpenConns(c.config.ConnSetMaxOpen)
+		c.sqlDd.SetMaxOpenConns(c.config.ConnSetMaxOpen)
 	}

 	// 设置了连接可复用的最大时间
 	if c.config.ConnSetConnMaxLifetime == 0 {
-		sqlDd.SetConnMaxLifetime(time.Hour)
+		c.sqlDd.SetConnMaxLifetime(time.Hour)
 	} else {
-		sqlDd.SetConnMaxLifetime(time.Duration(c.config.ConnSetConnMaxLifetime))
+		c.sqlDd.SetConnMaxLifetime(time.Duration(c.config.ConnSetConnMaxLifetime))
 	}

 	return c, nil
--- a/json.go
+++ b/json.go
@ -1,18 +0,0 @@
-package dorm
-
-import (
-	"go.dtapp.net/gojson"
-)
-
-// JsonDecodeNoError json字符串转结构体，不报错
-func JsonDecodeNoError(b []byte) map[string]interface{} {
-	var data map[string]interface{}
-	_ = gojson.Unmarshal(b, &data)
-	return data
-}
-
-// JsonEncodeNoError 结构体转json字符串，不报错
-func JsonEncodeNoError(data interface{}) string {
-	jsons, _ := gojson.Marshal(data)
-	return string(jsons)
-}
--- a/mongo.go
+++ b/mongo.go
@ -0,0 +1,67 @@
+package dorm
+
+import (
+	"context"
+	"errors"
+	"fmt"
+	"go.mongodb.org/mongo-driver/mongo"
+	"go.mongodb.org/mongo-driver/mongo/options"
+)
+
+// MongoClientFun *MongoClient 驱动
+// string 库名
+type MongoClientFun func() (*MongoClient, string)
+
+// MongoClientCollectionFun
+// *MongoClient 驱动
+// string 库名
+// string 集合
+type MongoClientCollectionFun func() (*MongoClient, string, string)
+
+// MongoClientConfig 实例配置
+type MongoClientConfig struct {
+	Dns          string // 地址
+	Opts         *options.ClientOptions
+	DatabaseName string // 库名
+}
+
+// MongoClient 实例
+type MongoClient struct {
+	db                 *mongo.Client // 驱动
+	configDatabaseName string        // 库名
+}
+
+// NewMongoClient 创建实例
+func NewMongoClient(ctx context.Context, config *MongoClientConfig) (*MongoClient, error) {
+
+	var err error
+	c := &MongoClient{}
+
+	c.configDatabaseName = config.DatabaseName
+
+	// 连接到MongoDB
+	if config.Dns != "" {
+		c.db, err = mongo.Connect(ctx, options.Client().ApplyURI(config.Dns))
+		if err != nil {
+			return nil, errors.New(fmt.Sprintf("连接失败：%v", err))
+		}
+	} else {
+		c.db, err = mongo.Connect(ctx, config.Opts)
+		if err != nil {
+			return nil, errors.New(fmt.Sprintf("连接失败：%v", err))
+		}
+	}
+
+	// 检查连接
+	err = c.db.Ping(ctx, nil)
+	if err != nil {
+		return nil, errors.New(fmt.Sprintf("检查连接失败：%v", err))
+	}
+
+	return c, nil
+}
+
+// Close 关闭
+func (c *MongoClient) Close(ctx context.Context) error {
+	return c.db.Disconnect(ctx)
+}
--- a/mongo_collection.go
+++ b/mongo_collection.go
@ -0,0 +1,60 @@
+package dorm
+
+import (
+	"context"
+	"go.mongodb.org/mongo-driver/bson"
+	"go.mongodb.org/mongo-driver/mongo"
+	"go.mongodb.org/mongo-driver/mongo/options"
+)
+
+type MongoCollectionOptions struct {
+	db                 *mongo.Client     // 驱动
+	configDatabaseName string            // 库名
+	dbCollection       *mongo.Collection // 集合
+}
+
+// Collection 选择集合
+func (cd *MongoDatabaseOptions) Collection(name string, opts ...*options.CollectionOptions) *MongoCollectionOptions {
+	return &MongoCollectionOptions{
+		db:                 cd.db,                                   // 驱动
+		configDatabaseName: cd.configDatabaseName,                   // 库名
+		dbCollection:       cd.dbDatabase.Collection(name, opts...), // 集合
+	}
+}
+
+// CreateOneIndexes 创建一个索引
+func (cc *MongoCollectionOptions) CreateOneIndexes(ctx context.Context, key string, value string) (string, error) {
+	return cc.dbCollection.Indexes().CreateOne(ctx, mongo.IndexModel{
+		Keys: bson.D{{
+			Key:   key,
+			Value: value,
+		}},
+	})
+}
+
+// CreateOneUniqueIndexes 创建一个唯一索引
+func (cc *MongoCollectionOptions) CreateOneUniqueIndexes(ctx context.Context, key string, value string) (string, error) {
+	return cc.dbCollection.Indexes().CreateOne(ctx, mongo.IndexModel{
+		Keys: bson.D{{
+			Key:   key,
+			Value: value,
+		}},
+		Options: options.Index().SetUnique(true),
+	})
+}
+
+// CreateOneUniqueIndexesOpts 创建一个索引
+func (cc *MongoCollectionOptions) CreateOneUniqueIndexesOpts(ctx context.Context, key string, value string, opts *options.IndexOptions) (string, error) {
+	return cc.dbCollection.Indexes().CreateOne(ctx, mongo.IndexModel{
+		Keys: bson.D{{
+			Key:   key,
+			Value: value,
+		}},
+		Options: opts,
+	})
+}
+
+// CreateManyIndexes 创建多个索引
+func (cc *MongoCollectionOptions) CreateManyIndexes(ctx context.Context, models []mongo.IndexModel) ([]string, error) {
+	return cc.dbCollection.Indexes().CreateMany(ctx, models)
+}
--- a/mongo_collection_curd.go
+++ b/mongo_collection_curd.go
@ -0,0 +1,100 @@
+package dorm
+
+import (
+	"context"
+	"go.mongodb.org/mongo-driver/mongo"
+	"go.mongodb.org/mongo-driver/mongo/options"
+)
+
+// InsertOne 插入一个文档
+func (cc *MongoCollectionOptions) InsertOne(ctx context.Context, document interface{}, opts ...*options.InsertOneOptions) (*mongo.InsertOneResult, error) {
+	return cc.dbCollection.InsertOne(ctx, document, opts...)
+}
+
+// InsertMany 插入多个文档
+func (cc *MongoCollectionOptions) InsertMany(ctx context.Context, document []interface{}, opts ...*options.InsertManyOptions) (*mongo.InsertManyResult, error) {
+	return cc.dbCollection.InsertMany(ctx, document, opts...)
+}
+
+// DeleteOne 删除一个文档
+func (cc *MongoCollectionOptions) DeleteOne(ctx context.Context, filter interface{}, opts ...*options.DeleteOptions) (*mongo.DeleteResult, error) {
+	return cc.dbCollection.DeleteOne(ctx, filter, opts...)
+}
+
+// DeleteMany 删除多个文档
+func (cc *MongoCollectionOptions) DeleteMany(ctx context.Context, filter interface{}, opts ...*options.DeleteOptions) (*mongo.DeleteResult, error) {
+	return cc.dbCollection.DeleteMany(ctx, filter, opts...)
+}
+
+// UpdateByID 按ID更新
+func (cc *MongoCollectionOptions) UpdateByID(ctx context.Context, id interface{}, update interface{}, opts ...*options.UpdateOptions) (*mongo.UpdateResult, error) {
+	return cc.dbCollection.UpdateByID(ctx, id, update, opts...)
+}
+
+// UpdateOne 更新一个文档
+func (cc *MongoCollectionOptions) UpdateOne(ctx context.Context, filter interface{}, update interface{}, opts ...*options.UpdateOptions) (*mongo.UpdateResult, error) {
+	return cc.dbCollection.UpdateOne(ctx, filter, update, opts...)
+}
+
+// UpdateMany 更新多个文档
+func (cc *MongoCollectionOptions) UpdateMany(ctx context.Context, filter interface{}, update interface{}, opts ...*options.UpdateOptions) (*mongo.UpdateResult, error) {
+	return cc.dbCollection.UpdateMany(ctx, filter, update, opts...)
+}
+
+// ReplaceOne 替换一个文档
+func (cc *MongoCollectionOptions) ReplaceOne(ctx context.Context, filter interface{}, update interface{}, opts ...*options.ReplaceOptions) (*mongo.UpdateResult, error) {
+	return cc.dbCollection.ReplaceOne(ctx, filter, update, opts...)
+}
+
+// Aggregate 统计分析
+func (cc *MongoCollectionOptions) Aggregate(ctx context.Context, pipeline interface{}, opts ...*options.AggregateOptions) (*mongo.Cursor, error) {
+	return cc.dbCollection.Aggregate(ctx, pipeline, opts...)
+}
+
+// CountDocuments 计数文档
+func (cc *MongoCollectionOptions) CountDocuments(ctx context.Context, filter interface{}, opts ...*options.CountOptions) (int64, error) {
+	return cc.dbCollection.CountDocuments(ctx, filter, opts...)
+}
+
+// EstimatedDocumentCount 估计文档计数
+func (cc *MongoCollectionOptions) EstimatedDocumentCount(ctx context.Context, opts ...*options.EstimatedDocumentCountOptions) (int64, error) {
+	return cc.dbCollection.EstimatedDocumentCount(ctx, opts...)
+}
+
+func (cc *MongoCollectionOptions) Distinct(ctx context.Context, fieldName string, filter interface{}, opts ...*options.DistinctOptions) ([]interface{}, error) {
+	return cc.dbCollection.Distinct(ctx, fieldName, filter, opts...)
+}
+
+// Find 查询多个文档
+func (cc *MongoCollectionOptions) Find(ctx context.Context, filter interface{}, opts ...*options.FindOptions) (*mongo.Cursor, error) {
+	return cc.dbCollection.Find(ctx, filter, opts...)
+}
+
+// FindOne 查询一个文档
+func (cc *MongoCollectionOptions) FindOne(ctx context.Context, filter interface{}, opts ...*options.FindOneOptions) *mongo.SingleResult {
+	return cc.dbCollection.FindOne(ctx, filter, opts...)
+}
+
+func (cc *MongoCollectionOptions) FindOneAndDelete(ctx context.Context, filter interface{}, opts ...*options.FindOneAndDeleteOptions) *mongo.SingleResult {
+	return cc.dbCollection.FindOneAndDelete(ctx, filter, opts...)
+}
+
+func (cc *MongoCollectionOptions) FindOneAndReplace(ctx context.Context, filter interface{}, replacement interface{}, opts ...*options.FindOneAndReplaceOptions) *mongo.SingleResult {
+	return cc.dbCollection.FindOneAndReplace(ctx, filter, replacement, opts...)
+}
+
+func (cc *MongoCollectionOptions) FindOneAndUpdate(ctx context.Context, filter interface{}, replacement interface{}, opts ...*options.FindOneAndUpdateOptions) *mongo.SingleResult {
+	return cc.dbCollection.FindOneAndUpdate(ctx, filter, replacement, opts...)
+}
+
+func (cc *MongoCollectionOptions) Watch(ctx context.Context, pipeline interface{}, opts ...*options.ChangeStreamOptions) (*mongo.ChangeStream, error) {
+	return cc.dbCollection.Watch(ctx, pipeline, opts...)
+}
+
+func (cc *MongoCollectionOptions) Indexes(ctx context.Context) mongo.IndexView {
+	return cc.dbCollection.Indexes()
+}
+
+func (cc *MongoCollectionOptions) Drop(ctx context.Context) error {
+	return cc.dbCollection.Drop(ctx)
+}
--- a/mongo_database.go
+++ b/mongo_database.go
@ -0,0 +1,69 @@
+package dorm
+
+import (
+	"context"
+	"go.mongodb.org/mongo-driver/mongo"
+	"go.mongodb.org/mongo-driver/mongo/options"
+	"reflect"
+)
+
+type MongoDatabaseOptions struct {
+	db                 *mongo.Client   // 驱动
+	configDatabaseName string          // 库名
+	dbDatabase         *mongo.Database // 数据库
+}
+
+// Database 选择数据库
+func (c *MongoClient) Database(name string, opts ...*options.DatabaseOptions) *MongoDatabaseOptions {
+	return &MongoDatabaseOptions{
+		db:                 c.db,                         // 驱动
+		configDatabaseName: c.configDatabaseName,         // 库名
+		dbDatabase:         c.db.Database(name, opts...), // 数据库
+	}
+}
+
+// CreateCollection 创建集合
+func (cd *MongoDatabaseOptions) CreateCollection(ctx context.Context, name string, opts ...*options.CreateCollectionOptions) error {
+	return cd.dbDatabase.CreateCollection(ctx, name, opts...)
+}
+
+// CreateTimeSeriesCollection 创建时间序列集合
+func (cd *MongoDatabaseOptions) CreateTimeSeriesCollection(ctx context.Context, name string, timeField string) error {
+	return cd.dbDatabase.CreateCollection(ctx, name, options.CreateCollection().SetTimeSeriesOptions(options.TimeSeries().SetTimeField(timeField)))
+}
+
+// Model 传入模型自动获取库名和表名
+// https://studygolang.com/articles/896
+// DatabaseName 库名
+// CollectionName 集合名
+func (c *MongoClient) Model(value interface{}) *MongoCollectionOptions {
+
+	var databaseOptions *MongoDatabaseOptions
+	var collectionOptions *MongoCollectionOptions
+
+	val := reflect.ValueOf(value)
+
+	methodDatabaseNameValue := val.MethodByName("DatabaseName")
+	if methodDatabaseNameValue.IsValid() {
+		databaseName := methodDatabaseNameValue.Call(nil)[0].String()
+		databaseOptions = c.Database(databaseName)
+	} else {
+		databaseOptions = c.Database(c.configDatabaseName)
+	}
+
+	methodCollectionNameValue := val.MethodByName("CollectionName")
+	if methodCollectionNameValue.IsValid() {
+		collectionName := methodCollectionNameValue.Call(nil)[0].String()
+		collectionOptions = databaseOptions.Collection(collectionName)
+	} else {
+		methodTableNameValue := val.MethodByName("TableName")
+		if methodTableNameValue.IsValid() {
+			collectionName := methodTableNameValue.Call(nil)[0].String()
+			collectionOptions = databaseOptions.Collection(collectionName)
+		} else {
+			panic(NoConfigCollectionName)
+		}
+	}
+
+	return collectionOptions
+}
--- a/mongo_error.go
+++ b/mongo_error.go
@ -0,0 +1,8 @@
+package dorm
+
+import "errors"
+
+var (
+	NoConfigDatabaseName   = errors.New("没有配置库名")
+	NoConfigCollectionName = errors.New("没有配置集合名")
+)
--- a/mongo_get.go
+++ b/mongo_get.go
@ -0,0 +1,8 @@
+package dorm
+
+import "go.mongodb.org/mongo-driver/mongo"
+
+// GetDb 获取驱动
+func (c *MongoClient) GetDb() *mongo.Client {
+	return c.db
+}
--- a/mongo_session.go
+++ b/mongo_session.go
@ -0,0 +1,59 @@
+package dorm
+
+import (
+	"context"
+	"go.mongodb.org/mongo-driver/mongo"
+	"log"
+)
+
+type MongoSessionOptions struct {
+	db                 *mongo.Client        // 驱动
+	configDatabaseName string               // 库名
+	session            mongo.Session        // 会话
+	sessionContext     mongo.SessionContext // 会话上下文
+}
+
+// Begin 开始事务，会同时创建开始会话需要在退出时关闭会话
+func (c *MongoClient) Begin() *MongoSessionOptions {
+
+	var ctx = context.TODO()
+	var err error
+	ms := &MongoSessionOptions{}
+
+	ms.db = c.GetDb()
+	ms.configDatabaseName = c.configDatabaseName
+
+	// 开始会话
+	ms.session, err = ms.db.StartSession()
+	if err != nil {
+		log.Println("开始会话异常：", err)
+	}
+
+	// 会话上下文
+	ms.sessionContext = mongo.NewSessionContext(ctx, ms.session)
+
+	// 会话开启事务
+	err = ms.session.StartTransaction()
+
+	return ms
+}
+
+// Rollback 回滚事务
+func (cs *MongoSessionOptions) Rollback() {
+	var ctx = context.TODO()
+	err := cs.session.AbortTransaction(ctx)
+	if err != nil {
+		log.Println("回滚事务异常：", err)
+	}
+	cs.session.EndSession(ctx)
+}
+
+// Commit 提交事务
+func (cs *MongoSessionOptions) Commit() {
+	var ctx = context.TODO()
+	err := cs.session.CommitTransaction(ctx)
+	if err != nil {
+		log.Println("提交事务异常：", err)
+	}
+	cs.session.EndSession(ctx)
+}
--- a/mongo_session_collection.go
+++ b/mongo_session_collection.go
@ -0,0 +1,25 @@
+package dorm
+
+import (
+	"go.mongodb.org/mongo-driver/mongo"
+	"go.mongodb.org/mongo-driver/mongo/options"
+)
+
+type MongoSessionCollectionOptions struct {
+	db                 *mongo.Client        // 驱动
+	configDatabaseName string               // 库名
+	session            mongo.Session        // 会话
+	sessionContext     mongo.SessionContext // 会话上下文
+	dbCollection       *mongo.Collection    // 集合
+}
+
+// Collection 选择集合
+func (csd *MongoSessionDatabaseOptions) Collection(name string, opts ...*options.CollectionOptions) *MongoSessionCollectionOptions {
+	return &MongoSessionCollectionOptions{
+		db:                 csd.db,                                   // 驱动
+		configDatabaseName: csd.configDatabaseName,                   // 库名
+		session:            csd.session,                              // 会话
+		sessionContext:     csd.sessionContext,                       // 会话上下文
+		dbCollection:       csd.dbDatabase.Collection(name, opts...), // 集合
+	}
+}
--- a/mongo_session_collection_curd.go
+++ b/mongo_session_collection_curd.go
@ -0,0 +1,99 @@
+package dorm
+
+import (
+	"go.mongodb.org/mongo-driver/mongo"
+	"go.mongodb.org/mongo-driver/mongo/options"
+)
+
+// InsertOne 插入一个文档
+func (csc *MongoSessionCollectionOptions) InsertOne(document interface{}, opts ...*options.InsertOneOptions) (*mongo.InsertOneResult, error) {
+	return csc.dbCollection.InsertOne(csc.sessionContext, document, opts...)
+}
+
+// InsertMany 插入多个文档
+func (csc *MongoSessionCollectionOptions) InsertMany(document []interface{}, opts ...*options.InsertManyOptions) (*mongo.InsertManyResult, error) {
+	return csc.dbCollection.InsertMany(csc.sessionContext, document, opts...)
+}
+
+// DeleteOne 删除一个文档
+func (csc *MongoSessionCollectionOptions) DeleteOne(filter interface{}, opts ...*options.DeleteOptions) (*mongo.DeleteResult, error) {
+	return csc.dbCollection.DeleteOne(csc.sessionContext, filter, opts...)
+}
+
+// DeleteMany 删除多个文档
+func (csc *MongoSessionCollectionOptions) DeleteMany(filter interface{}, opts ...*options.DeleteOptions) (*mongo.DeleteResult, error) {
+	return csc.dbCollection.DeleteMany(csc.sessionContext, filter, opts...)
+}
+
+// UpdateByID 按ID更新
+func (csc *MongoSessionCollectionOptions) UpdateByID(id interface{}, update interface{}, opts ...*options.UpdateOptions) (*mongo.UpdateResult, error) {
+	return csc.dbCollection.UpdateByID(csc.sessionContext, id, update, opts...)
+}
+
+// UpdateOne 更新一个文档
+func (csc *MongoSessionCollectionOptions) UpdateOne(filter interface{}, update interface{}, opts ...*options.UpdateOptions) (*mongo.UpdateResult, error) {
+	return csc.dbCollection.UpdateOne(csc.sessionContext, filter, update, opts...)
+}
+
+// UpdateMany 更新多个文档
+func (csc *MongoSessionCollectionOptions) UpdateMany(filter interface{}, update interface{}, opts ...*options.UpdateOptions) (*mongo.UpdateResult, error) {
+	return csc.dbCollection.UpdateMany(csc.sessionContext, filter, update, opts...)
+}
+
+// ReplaceOne 替换一个文档
+func (csc *MongoSessionCollectionOptions) ReplaceOne(filter interface{}, update interface{}, opts ...*options.ReplaceOptions) (*mongo.UpdateResult, error) {
+	return csc.dbCollection.ReplaceOne(csc.sessionContext, filter, update, opts...)
+}
+
+// Aggregate 统计分析
+func (csc *MongoSessionCollectionOptions) Aggregate(pipeline interface{}, opts ...*options.AggregateOptions) (*mongo.Cursor, error) {
+	return csc.dbCollection.Aggregate(csc.sessionContext, pipeline, opts...)
+}
+
+// CountDocuments 计数文档
+func (csc *MongoSessionCollectionOptions) CountDocuments(filter interface{}, opts ...*options.CountOptions) (int64, error) {
+	return csc.dbCollection.CountDocuments(csc.sessionContext, filter, opts...)
+}
+
+// EstimatedDocumentCount 估计文档计数
+func (csc *MongoSessionCollectionOptions) EstimatedDocumentCount(opts ...*options.EstimatedDocumentCountOptions) (int64, error) {
+	return csc.dbCollection.EstimatedDocumentCount(csc.sessionContext, opts...)
+}
+
+func (csc *MongoSessionCollectionOptions) Distinct(fieldName string, filter interface{}, opts ...*options.DistinctOptions) ([]interface{}, error) {
+	return csc.dbCollection.Distinct(csc.sessionContext, fieldName, filter, opts...)
+}
+
+// Find 查询多个文档
+func (csc *MongoSessionCollectionOptions) Find(filter interface{}, opts ...*options.FindOptions) (*mongo.Cursor, error) {
+	return csc.dbCollection.Find(csc.sessionContext, filter, opts...)
+}
+
+// FindOne 查询一个文档
+func (csc *MongoSessionCollectionOptions) FindOne(filter interface{}, opts ...*options.FindOneOptions) *mongo.SingleResult {
+	return csc.dbCollection.FindOne(csc.sessionContext, filter, opts...)
+}
+
+func (csc *MongoSessionCollectionOptions) FindOneAndDelete(filter interface{}, opts ...*options.FindOneAndDeleteOptions) *mongo.SingleResult {
+	return csc.dbCollection.FindOneAndDelete(csc.sessionContext, filter, opts...)
+}
+
+func (csc *MongoSessionCollectionOptions) FindOneAndReplace(filter interface{}, replacement interface{}, opts ...*options.FindOneAndReplaceOptions) *mongo.SingleResult {
+	return csc.dbCollection.FindOneAndReplace(csc.sessionContext, filter, replacement, opts...)
+}
+
+func (csc *MongoSessionCollectionOptions) FindOneAndUpdate(filter interface{}, replacement interface{}, opts ...*options.FindOneAndUpdateOptions) *mongo.SingleResult {
+	return csc.dbCollection.FindOneAndUpdate(csc.sessionContext, filter, replacement, opts...)
+}
+
+func (csc *MongoSessionCollectionOptions) Watch(pipeline interface{}, opts ...*options.ChangeStreamOptions) (*mongo.ChangeStream, error) {
+	return csc.dbCollection.Watch(csc.sessionContext, pipeline, opts...)
+}
+
+func (csc *MongoSessionCollectionOptions) Indexes() mongo.IndexView {
+	return csc.dbCollection.Indexes()
+}
+
+func (csc *MongoSessionCollectionOptions) Drop() error {
+	return csc.dbCollection.Drop(csc.sessionContext)
+}
--- a/mongo_session_database.go
+++ b/mongo_session_database.go
@ -0,0 +1,62 @@
+package dorm
+
+import (
+	"go.mongodb.org/mongo-driver/mongo"
+	"go.mongodb.org/mongo-driver/mongo/options"
+	"reflect"
+)
+
+type MongoSessionDatabaseOptions struct {
+	db                 *mongo.Client        // 驱动
+	configDatabaseName string               // 库名
+	session            mongo.Session        // 会话
+	sessionContext     mongo.SessionContext // 会话上下文
+	dbDatabase         *mongo.Database      // 数据库
+}
+
+// Database 选择数据库
+func (cs *MongoSessionOptions) Database(name string, opts ...*options.DatabaseOptions) *MongoSessionDatabaseOptions {
+	return &MongoSessionDatabaseOptions{
+		db:                 cs.db,                         // 驱动
+		configDatabaseName: cs.configDatabaseName,         // 库名
+		session:            cs.session,                    // 会话
+		sessionContext:     cs.sessionContext,             // 会话上下文
+		dbDatabase:         cs.db.Database(name, opts...), // 数据库
+	}
+}
+
+// Model 传入模型自动获取库名和表名
+// https://studygolang.com/articles/896
+// DatabaseName 库名
+// CollectionName 集合名
+func (cs *MongoSessionOptions) Model(value interface{}) *MongoSessionCollectionOptions {
+
+	var sessionDatabaseOptions *MongoSessionDatabaseOptions
+	var sessionCollectionOptions *MongoSessionCollectionOptions
+
+	val := reflect.ValueOf(value)
+
+	methodDatabaseNameValue := val.MethodByName("DatabaseName")
+	if methodDatabaseNameValue.IsValid() {
+		databaseName := methodDatabaseNameValue.Call(nil)[0].String()
+		sessionDatabaseOptions = cs.Database(databaseName)
+	} else {
+		sessionDatabaseOptions = cs.Database(cs.configDatabaseName)
+	}
+
+	methodCollectionNameValue := val.MethodByName("CollectionName")
+	if methodCollectionNameValue.IsValid() {
+		collectionName := methodCollectionNameValue.Call(nil)[0].String()
+		sessionCollectionOptions = sessionDatabaseOptions.Collection(collectionName)
+	} else {
+		methodTableNameValue := val.MethodByName("TableName")
+		if methodTableNameValue.IsValid() {
+			collectionName := methodTableNameValue.Call(nil)[0].String()
+			sessionCollectionOptions = sessionDatabaseOptions.Collection(collectionName)
+		} else {
+			panic(NoConfigCollectionName)
+		}
+	}
+
+	return sessionCollectionOptions
+}
--- a/mongo_session_get.go
+++ b/mongo_session_get.go
@ -0,0 +1,18 @@
+package dorm
+
+import "go.mongodb.org/mongo-driver/mongo"
+
+// GetDb 获取驱动
+func (cs *MongoSessionOptions) GetDb() *mongo.Client {
+	return cs.db
+}
+
+// GetSession 获取会话
+func (cs *MongoSessionOptions) GetSession() mongo.Session {
+	return cs.session
+}
+
+// GetSessionContext 获取会话上下文
+func (cs *MongoSessionOptions) GetSessionContext() mongo.SessionContext {
+	return cs.sessionContext
+}
--- a/mongo_time.go
+++ b/mongo_time.go
@ -0,0 +1,85 @@
+package dorm
+
+import (
+	"go.dtapp.net/gotime"
+	"go.mongodb.org/mongo-driver/bson"
+	"go.mongodb.org/mongo-driver/bson/bsontype"
+	"time"
+)
+
+// BsonTime 时间类型
+type BsonTime time.Time
+
+// MarshalJSON 实现json序列化
+func (bt BsonTime) MarshalJSON() ([]byte, error) {
+
+	b := make([]byte, 0)
+	b = append(b, '"')
+	b = append(b, gotime.SetCurrent(time.Time(bt)).Bson()...)
+	b = append(b, '"')
+
+	return b, nil
+}
+
+// UnmarshalJSON 实现json反序列化
+func (bt *BsonTime) UnmarshalJSON(data []byte) (err error) {
+
+	if string(data) == "null" {
+		return nil
+	}
+
+	bsonTime := gotime.SetCurrentParse(string(data))
+	*bt = BsonTime(bsonTime.Time)
+
+	return nil
+}
+
+// Time 转时间
+func (bt BsonTime) Time() time.Time {
+	return gotime.SetCurrent(time.Time(bt)).Time
+}
+
+// Format 转时间字符串
+func (bt BsonTime) Format() string {
+	return gotime.SetCurrent(time.Time(bt)).Format()
+}
+
+// TimePro 转时间操作
+func (bt BsonTime) TimePro() gotime.Pro {
+	return gotime.SetCurrent(time.Time(bt))
+}
+
+// NewBsonTimeCurrent 创建当前时间
+func NewBsonTimeCurrent() BsonTime {
+	return BsonTime(gotime.Current().Time)
+}
+
+// NewBsonTimeFromTime 创建某个时间
+func NewBsonTimeFromTime(t time.Time) BsonTime {
+	return BsonTime(t)
+}
+
+// NewBsonTimeFromString 创建某个时间 字符串
+func NewBsonTimeFromString(t string) BsonTime {
+	return BsonTime(gotime.SetCurrentParse(t).Time)
+}
+
+// Value 时间类型
+func (bt BsonTime) Value() string {
+	return gotime.SetCurrent(time.Time(bt)).Bson()
+}
+
+// MarshalBSONValue 实现bson序列化
+func (bt BsonTime) MarshalBSONValue() (bsontype.Type, []byte, error) {
+	return bson.MarshalValue(gotime.SetCurrent(time.Time(bt)).Bson())
+}
+
+// UnmarshalBSONValue 实现bson反序列化
+func (bt *BsonTime) UnmarshalBSONValue(t bsontype.Type, data []byte) error {
+	t1 := gotime.SetCurrentParse(string(data))
+	//if string(data) == "" {
+	//	return errors.New(fmt.Sprintf("%s, %s, %s", "读取数据失败:", t, data))
+	//}
+	*bt = BsonTime(t1.Time)
+	return nil
+}
--- a/redis.go
+++ b/redis.go
@ -22,29 +22,29 @@ type RedisClientConfig struct {
 // RedisClient
 // https://redis.uptrace.dev/
 type RedisClient struct {
-	db     *redis.Client      // 驱动
-	config *RedisClientConfig // 配置
+	db *redis.Client // 驱动
 }

+// NewRedisClient 创建实例
 func NewRedisClient(config *RedisClientConfig) (*RedisClient, error) {

 	c := &RedisClient{}
-	c.config = config
-	if c.config.PoolSize == 0 {
-		c.config.PoolSize = 100
+	if config.PoolSize == 0 {
+		config.PoolSize = 100
 	}

 	c.db = redis.NewClient(&redis.Options{
-		Addr:        c.config.Addr,        // 地址
-		Password:    c.config.Password,    // 密码
-		DB:          c.config.DB,          // 数据库
-		PoolSize:    c.config.PoolSize,    // 连接池大小
-		ReadTimeout: c.config.ReadTimeout, // 读取超时
+		Addr:        config.Addr,        // 地址
+		Password:    config.Password,    // 密码
+		DB:          config.DB,          // 数据库
+		PoolSize:    config.PoolSize,    // 连接池大小
+		ReadTimeout: config.ReadTimeout, // 读取超时
 	})

 	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
 	defer cancel()

+	// 检测 Redis 连接是否正常连接
 	_, err := c.db.Ping(ctx).Result()
 	if err != nil {
 		return nil, errors.New(fmt.Sprintf("连接失败：%v", err))
@ -52,3 +52,28 @@ func NewRedisClient(config *RedisClientConfig) (*RedisClient, error) {

 	return c, nil
 }
+
+// NewRedisClientURL 创建实例
+func NewRedisClientURL(redisURL string) (*RedisClient, error) {
+
+	c := &RedisClient{}
+
+	opt, err := redis.ParseURL(redisURL)
+	if err != nil {
+		return c, nil
+	}
+
+	// 创建 Redis 客户端
+	c.db = redis.NewClient(opt)
+
+	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
+	defer cancel()
+
+	// 检测 Redis 连接是否正常连接
+	_, err = c.db.Ping(ctx).Result()
+	if err != nil {
+		return nil, errors.New(fmt.Sprintf("连接失败：%v", err))
+	}
+
+	return c, nil
+}
--- a/redis_hash_operation.go
+++ b/redis_hash_operation.go
@ -5,6 +5,7 @@ import (
 	"github.com/redis/go-redis/v9"
 )

+// HashOperation Hash类型数据操作
 type HashOperation struct {
 	db *redis.Client
 }
--- a/redis_list_operation.go
+++ b/redis_list_operation.go
@ -5,6 +5,7 @@ import (
 	"github.com/redis/go-redis/v9"
 )

+// ListOperation  列表(list)类型数据操作
 type ListOperation struct {
 	db  *redis.Client
 	ctx context.Context
--- a/version.go
+++ b/version.go
@ -0,0 +1,4 @@
+package dorm
+
+// Version 版本
+const Version = "1.0.59"
--- a/vsrsion.go
+++ b/vsrsion.go
@ -1,3 +0,0 @@
-package dorm
-
-const Version = "1.0.55"
--- a/xml.go
+++ b/xml.go
@ -1,21 +0,0 @@
-package dorm
-
-import (
-	"github.com/basgys/goxml2json"
-	"go.dtapp.net/gojson"
-	"strings"
-)
-
-// XmlDecodeNoError xml字符串转结构体，不报错
-func XmlDecodeNoError(b []byte) map[string]interface{} {
-	xtj := strings.NewReader(string(b))
-	jtx, _ := xml2json.Convert(xtj)
-	var data map[string]interface{}
-	_ = gojson.Unmarshal(jtx.Bytes(), &data)
-	return data
-}
-
-// XmlEncodeNoError 结构体转json字符串，不报错
-func XmlEncodeNoError(data interface{}) string {
-	return JsonEncodeNoError(data)
-}
Author	SHA1	Message	Date
dtapps	5f70e83104	- update mod	2 days ago
dtapps	8dbbff4a27	- update vendor	4 weeks ago
dtapps	0ed080ee44	- redis增加url连接	4 weeks ago
dtapps	b99cbca10a	- update	4 weeks ago
dtapps	8238616ab5	- update	4 weeks ago
dtapps	b4cf941dd9	- update vendor	1 month ago
dtapps	1f3831a39c	- add vendor	1 month ago
dtapps	bb1ce11d98	- update gorm sql	2 months ago
dtapps	0799a47c4d	- update mongo	3 months ago