+ Added releaseSavepoint() method

src/Connection.ts

@@ -178,14 +178,6 @@ export class Connection extends SafeEventEmitter {
         return this._intlCon.startTransaction();
     }
 
-    /**
-     * Starts transaction and creates a savepoint
-     * @param name {string} - Name of the savepoint
-     */
-    savepoint(name: string): Promise<void> {
-        return this._intlCon.savepoint(name);
-    }
-
     /**
      * Commits current transaction
      */
@@ -200,6 +192,16 @@ export class Connection extends SafeEventEmitter {
         return this._intlCon.rollback();
     }
 
+    /**
+     * Starts transaction and creates a savepoint
+     * @param name {string} - Name of the savepoint
+     */
+    async savepoint(name: string): Promise<void> {
+        if (!this._intlCon.inTransaction)
+            await this._intlCon.startTransaction();
+        return this._intlCon.savepoint(name);
+    }
+
     /**
      * Rolls back current transaction to given savepoint
      * @param name {string} - Name of the savepoint
@@ -208,6 +210,14 @@ export class Connection extends SafeEventEmitter {
         return this._intlCon.rollbackToSavepoint(name);
     }
 
+    /**
+     * Releases savepoint
+     * @param name {string} - Name of the savepoint
+     */
+    releaseSavepoint(name: string): Promise<void> {
+        return this._intlCon.releaseSavepoint(name);
+    }
+
     protected async _close(): Promise<void> {
         if (this._pool) {
             await this._pool.release(this);

src/IntlConnection.ts

@@ -173,6 +173,12 @@ export class IntlConnection extends SafeEventEmitter {
         await this.execute('ROLLBACK TO SAVEPOINT ' + name, {autoCommit: false});
     }
 
+    async releaseSavepoint(name: string): Promise<void> {
+        if (!(name && name.match(/^[a-zA-Z]\w+$/)))
+            throw new Error(`Invalid savepoint "${name}`);
+        await this.execute('RELEASE SAVEPOINT ' + name, {autoCommit: false});
+    }
+
     ref(): void {
         this._refCount++;
         debug('[%s] ref %d', this.processID, this._refCount);