ts支持savepoint

generator/client/typescript/templates/queryx/adapter.mysql.ts

@@ -48,6 +48,17 @@ export class Adapter {
  async rollback() {
  await this.db.query("ROLLBACK");
  }
+
+ async savePoint(sp: string){
+ await this.exec(`SAVEPOINT ${sp}`);
+ }
+ async releasePoint(rp: string){
+ await this.exec(`RELEASE SAVEPOINT ${rp}`);
+ }
+
+ async rollbackTo(rt: string){
+ await this.exec(`ROLLBACK TO ${rt}`);
+ }
 }
 
 export function rebind<T extends any[] = any[]>(query: string, args?: T) {}

generator/client/typescript/templates/queryx/adapter.postgresql.ts

@@ -53,6 +53,18 @@ export class Adapter {
  async rollback() {
  await this.exec("ROLLBACK");
  }
+
+ async savePoint(sp: string){
+ await this.exec(`SAVEPOINT ${sp}`);
+ }
+ async releasePoint(rp: string){
+ await this.exec(`RELEASE SAVEPOINT ${rp}`);
+ }
+
+ async rollbackTo(rt: string){
+ await this.exec(`ROLLBACK TO ${rt}`);
+ }
+
 }
 
 export function rebind<T extends any[] = any[]>(query: string, args?: T) {

generator/client/typescript/templates/queryx/adapter.sqlite.ts

@@ -44,6 +44,17 @@ export class Adapter {
  async rollback() {
  await this.exec("ROLLBACK");
  }
+
+ async savePoint(sp: string){
+ await this.exec(`SAVEPOINT ${sp}`);
+ }
+ async releasePoint(rp: string){
+ await this.exec(`RELEASE SAVEPOINT ${rp}`);
+ }
+
+ async rollbackTo(rt: string){
+ await this.exec(`ROLLBACK TO ${rt}`);
+ }
 }
 
 export function rebind<T extends any[] = any[]>(query: string, args?: T) {

generator/client/typescript/templates/queryx/client.tstmpl

@@ -75,6 +75,18 @@ export class Tx extends QXClient {
  rollback() {
  return this.adapter.rollback();
  }
+
+ savePoint(sp: string){
+ return this.adapter.savePoint(sp)
+ }
+
+ releasePoint(rp: string){
+ return this.adapter.releasePoint(rp)
+ }
+
+ rollbackTo(rt: string){
+ return this.adapter.rollbackTo(rt)
+ }
 }
 
 export const newClient = () => {

internal/integration/client.test.ts

@@ -345,6 +345,24 @@ test("transaction", async () => {
  expect(tag1.name).toEqual("tag1-updated");
 });
 
+
+test("savepoint", async () => {
+ let tx = await c.tx();
+ let tagPoint = "sp_point"
+
+ await tx.queryTag().create({name:"tagPoint1"})
+ await tx.savePoint(tagPoint)
+
+ await tx.queryTag().create({name: "tagPoint2"})
+ await tx.rollbackTo(tagPoint)
+
+ await tx.queryTag().where(tx.tagName.eq("tagPoint1")).exists()
+ await tx.queryTag().where(tx.tagName.eq("tagPoint2")).exists()
+
+ await tx.releasePoint(tagPoint)
+ await tx.commit()
+});
+
 test("changeJSON", async () => {
  let userChange = new UserChange({
  name: "user name",