@@ -114,7 +114,7 @@ async fn commit_with_serialization_failure_already_ends_transaction() {
114
114
use tokio:: sync:: Barrier ;
115
115
116
116
table ! {
117
- users3 {
117
+ users4 {
118
118
id -> Integer ,
119
119
}
120
120
}
@@ -139,7 +139,7 @@ async fn commit_with_serialization_failure_already_ends_transaction() {
139
139
140
140
let mut conn1 = super :: connection_without_transaction ( ) . await ;
141
141
142
- diesel:: sql_query ( "CREATE TABLE IF NOT EXISTS users3 (id int);" )
142
+ diesel:: sql_query ( "CREATE TABLE IF NOT EXISTS users4 (id int);" )
143
143
. execute ( & mut conn)
144
144
. await
145
145
. unwrap ( ) ;
@@ -155,11 +155,11 @@ async fn commit_with_serialization_failure_already_ends_transaction() {
155
155
156
156
let res = tx. run ( |conn| {
157
157
Box :: pin ( async {
158
- users3 :: table. select ( users3 :: id) . load :: < i32 > ( conn) . await ?;
158
+ users4 :: table. select ( users4 :: id) . load :: < i32 > ( conn) . await ?;
159
159
160
160
barrier_1_for_tx1. wait ( ) . await ;
161
- diesel:: insert_into ( users3 :: table)
162
- . values ( users3 :: id. eq ( 1 ) )
161
+ diesel:: insert_into ( users4 :: table)
162
+ . values ( users4 :: id. eq ( 1 ) )
163
163
. execute ( conn)
164
164
. await ?;
165
165
barrier_2_for_tx1. wait ( ) . await ;
@@ -174,11 +174,11 @@ async fn commit_with_serialization_failure_already_ends_transaction() {
174
174
let res = tx1
175
175
. run ( |conn| {
176
176
Box :: pin ( async {
177
- users3 :: table. select ( users3 :: id) . load :: < i32 > ( conn) . await ?;
177
+ users4 :: table. select ( users4 :: id) . load :: < i32 > ( conn) . await ?;
178
178
179
179
barrier_1_for_tx2. wait ( ) . await ;
180
- diesel:: insert_into ( users3 :: table)
181
- . values ( users3 :: id. eq ( 1 ) )
180
+ diesel:: insert_into ( users4 :: table)
181
+ . values ( users4 :: id. eq ( 1 ) )
182
182
. execute ( conn)
183
183
. await ?;
184
184
0 commit comments