@@ -341,7 +341,7 @@ export class Kysely<DB>
341
341
*
342
342
* await trx.commit().execute()
343
343
*
344
- * return catto
344
+ * // ...
345
345
* } catch (error) {
346
346
* await trx.rollback().execute()
347
347
* }
@@ -375,20 +375,19 @@ export class Kysely<DB>
375
375
* const trxAfterJennifer = await trx.savepoint('after_jennifer').execute()
376
376
*
377
377
* try {
378
- * const bone = await trxAfterJennifer
379
- * .insertInto('toy')
380
- * .values({ name: 'Bone', price: 1.99 })
381
- * .returning('id')
382
- * .executeTakeFirstOrThrow()
383
- *
384
- * await trxAfterJennifer
378
+ * const catto = await trxAfterJennifer
385
379
* .insertInto('pet')
386
380
* .values({
387
381
* owner_id: jennifer.id,
388
382
* name: 'Catto',
389
383
* species: 'cat',
390
- * favorite_toy_id: bone.id,
391
384
* })
385
+ * .returning('id')
386
+ * .executeTakeFirstOrThrow()
387
+ *
388
+ * await trxAfterJennifer
389
+ * .insertInto('toy')
390
+ * .values({ name: 'Bone', price: 1.99, pet_id: catto.id })
392
391
* .execute()
393
392
* } catch (error) {
394
393
* await trxAfterJennifer.rollbackToSavepoint('after_jennifer').execute()
@@ -838,13 +837,20 @@ export class ControlledTransaction<
838
837
* ### Examples
839
838
*
840
839
* ```ts
840
+ * import type { Kysely } from 'kysely'
841
+ * import type { Database } from 'type-editor' // imaginary module
842
+ *
843
+ * const trx = await db.startTransaction().execute()
844
+ *
841
845
* try {
842
846
* await doSomething(trx)
843
847
*
844
848
* await trx.commit().execute()
845
849
* } catch (error) {
846
850
* await trx.rollback().execute()
847
851
* }
852
+ *
853
+ * async function doSomething(kysely: Kysely<Database>) {}
848
854
* ```
849
855
*/
850
856
commit ( ) : Command < void > {
@@ -865,13 +871,20 @@ export class ControlledTransaction<
865
871
* ### Examples
866
872
*
867
873
* ```ts
874
+ * import type { Kysely } from 'kysely'
875
+ * import type { Database } from 'type-editor' // imaginary module
876
+ *
877
+ * const trx = await db.startTransaction().execute()
878
+ *
868
879
* try {
869
880
* await doSomething(trx)
870
881
*
871
882
* await trx.commit().execute()
872
883
* } catch (error) {
873
884
* await trx.rollback().execute()
874
885
* }
886
+ *
887
+ * async function doSomething(kysely: Kysely<Database>) {}
875
888
* ```
876
889
*/
877
890
rollback ( ) : Command < void > {
@@ -894,15 +907,23 @@ export class ControlledTransaction<
894
907
* ### Examples
895
908
*
896
909
* ```ts
897
- * await insertJennifer(trx)
910
+ * import type { Kysely } from 'kysely'
911
+ * import type { Database } from 'type-editor' // imaginary module
898
912
*
899
- * const trxAfterJennifer = await trx.savepoint('after_jennifer' ).execute()
913
+ * const trx = await db.startTransaction( ).execute()
900
914
*
901
- * try {
902
- * await doSomething(trxAfterJennifer)
903
- * } catch (error) {
904
- * await trxAfterJennifer.rollbackToSavepoint('after_jennifer').execute()
905
- * }
915
+ * await insertJennifer(trx)
916
+ *
917
+ * const trxAfterJennifer = await trx.savepoint('after_jennifer').execute()
918
+ *
919
+ * try {
920
+ * await doSomething(trxAfterJennifer)
921
+ * } catch (error) {
922
+ * await trxAfterJennifer.rollbackToSavepoint('after_jennifer').execute()
923
+ * }
924
+ *
925
+ * async function insertJennifer(kysely: Kysely<Database>) {}
926
+ * async function doSomething(kysely: Kysely<Database>) {}
906
927
* ```
907
928
*/
908
929
savepoint < SN extends string > (
@@ -932,15 +953,23 @@ export class ControlledTransaction<
932
953
* ### Examples
933
954
*
934
955
* ```ts
935
- * await insertJennifer(trx)
956
+ * import type { Kysely } from 'kysely'
957
+ * import type { Database } from 'type-editor' // imaginary module
936
958
*
937
- * const trxAfterJennifer = await trx.savepoint('after_jennifer' ).execute()
959
+ * const trx = await db.startTransaction( ).execute()
938
960
*
939
- * try {
940
- * await doSomething(trxAfterJennifer)
941
- * } catch (error) {
942
- * await trxAfterJennifer.rollbackToSavepoint('after_jennifer').execute()
943
- * }
961
+ * await insertJennifer(trx)
962
+ *
963
+ * const trxAfterJennifer = await trx.savepoint('after_jennifer').execute()
964
+ *
965
+ * try {
966
+ * await doSomething(trxAfterJennifer)
967
+ * } catch (error) {
968
+ * await trxAfterJennifer.rollbackToSavepoint('after_jennifer').execute()
969
+ * }
970
+ *
971
+ * async function insertJennifer(kysely: Kysely<Database>) {}
972
+ * async function doSomething(kysely: Kysely<Database>) {}
944
973
* ```
945
974
*/
946
975
rollbackToSavepoint < SN extends S [ number ] > (
@@ -972,19 +1001,28 @@ export class ControlledTransaction<
972
1001
* ### Examples
973
1002
*
974
1003
* ```ts
975
- * await insertJennifer(trx)
1004
+ * import type { Kysely } from 'kysely'
1005
+ * import type { Database } from 'type-editor' // imaginary module
976
1006
*
977
- * const trxAfterJennifer = await trx.savepoint('after_jennifer' ).execute()
1007
+ * const trx = await db.startTransaction( ).execute()
978
1008
*
979
- * try {
980
- * await doSomething(trxAfterJennifer)
981
- * } catch (error) {
982
- * await trxAfterJennifer.rollbackToSavepoint('after_jennifer').execute()
983
- * }
1009
+ * await insertJennifer(trx)
984
1010
*
985
- * await trxAfterJennifer.releaseSavepoint('after_jennifer').execute()
1011
+ * const trxAfterJennifer = await trx.savepoint('after_jennifer').execute()
1012
+ *
1013
+ * try {
1014
+ * await doSomething(trxAfterJennifer)
1015
+ * } catch (error) {
1016
+ * await trxAfterJennifer.rollbackToSavepoint('after_jennifer').execute()
1017
+ * }
1018
+ *
1019
+ * await trxAfterJennifer.releaseSavepoint('after_jennifer').execute()
1020
+ *
1021
+ * await doSomethingElse(trx)
986
1022
*
987
- * await doSomethingElse(trx)
1023
+ * async function insertJennifer(kysely: Kysely<Database>) {}
1024
+ * async function doSomething(kysely: Kysely<Database>) {}
1025
+ * async function doSomethingElse(kysely: Kysely<Database>) {}
988
1026
* ```
989
1027
*/
990
1028
releaseSavepoint < SN extends S [ number ] > (
0 commit comments