-
-
Notifications
You must be signed in to change notification settings - Fork 195
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
feat: add support for better-sqlite3
- Loading branch information
1 parent
b991e82
commit 5d006b8
Showing
12 changed files
with
202 additions
and
126 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,17 @@ | ||
| /* | ||
| * @adonisjs/lucid | ||
| * | ||
| * (c) Harminder Virk <[email protected]> | ||
| * | ||
| * For the full copyright and license information, please view the LICENSE | ||
| * file that was distributed with this source code. | ||
| */ | ||
|
|
||
| /// <reference path="../../adonis-typings/index.ts" /> | ||
|
|
||
| import { DialectContract } from '@ioc:Adonis/Lucid/Database' | ||
| import { BaseSqliteDialect } from './SqliteBase' | ||
|
|
||
| export class BetterSqliteDialect extends BaseSqliteDialect implements DialectContract { | ||
| public readonly name = 'better-sqlite3' | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,119 @@ | ||
| /* | ||
| * @adonisjs/lucid | ||
| * | ||
| * (c) Harminder Virk <[email protected]> | ||
| * | ||
| * For the full copyright and license information, please view the LICENSE | ||
| * file that was distributed with this source code. | ||
| */ | ||
|
|
||
| /// <reference path="../../adonis-typings/index.ts" /> | ||
|
|
||
| import { DialectContract, QueryClientContract } from '@ioc:Adonis/Lucid/Database' | ||
|
|
||
| export abstract class BaseSqliteDialect implements DialectContract { | ||
| public abstract readonly name: 'sqlite3' | 'better-sqlite3' | ||
| public readonly supportsAdvisoryLocks = false | ||
|
|
||
| /** | ||
| * Reference to the database version. Knex.js fetches the version after | ||
| * the first database query, so it will be set to undefined initially | ||
| */ | ||
| public readonly version = this.client.getReadClient()['context']['client'].version | ||
|
|
||
| /** | ||
| * The default format for datetime column. The date formats is | ||
| * valid for luxon date parsing library | ||
| */ | ||
| public readonly dateTimeFormat = 'yyyy-MM-dd HH:mm:ss' | ||
|
|
||
| constructor(private client: QueryClientContract) {} | ||
|
|
||
| /** | ||
| * Returns an array of table names | ||
| */ | ||
| public async getAllTables() { | ||
| const tables = await this.client | ||
| .query() | ||
| .from('sqlite_master') | ||
| .select('name as table_name') | ||
| .where('type', 'table') | ||
| .whereNot('name', 'like', 'sqlite_%') | ||
| .orderBy('name', 'asc') | ||
|
|
||
| return tables.map(({ table_name }) => table_name) | ||
| } | ||
|
|
||
| /** | ||
| * Returns an array of all views names | ||
| */ | ||
| public async getAllViews(): Promise<string[]> { | ||
| const tables = await this.client | ||
| .query() | ||
| .from('sqlite_master') | ||
| .select('name as table_name') | ||
| .where('type', 'view') | ||
| .whereNot('name', 'like', 'sqlite_%') | ||
| .orderBy('name', 'asc') | ||
|
|
||
| return tables.map(({ table_name }) => table_name) | ||
| } | ||
|
|
||
| /** | ||
| * Returns an array of all types names | ||
| */ | ||
| public async getAllTypes(): Promise<string[]> { | ||
| throw new Error("Sqlite doesn't support types") | ||
| } | ||
|
|
||
| /** | ||
| * Truncate SQLITE tables | ||
| */ | ||
| public async truncate(table: string) { | ||
| return this.client.knexQuery().table(table).truncate() | ||
| } | ||
|
|
||
| /** | ||
| * Drop all tables inside the database | ||
| */ | ||
| public async dropAllTables() { | ||
| await this.client.rawQuery('PRAGMA writable_schema = 1;') | ||
| await this.client.rawQuery( | ||
| `delete from sqlite_master where type in ('table', 'index', 'trigger');` | ||
| ) | ||
| await this.client.rawQuery('PRAGMA writable_schema = 0;') | ||
| await this.client.rawQuery('VACUUM;') | ||
| } | ||
|
|
||
| /** | ||
| * Drop all views inside the database | ||
| */ | ||
| public async dropAllViews(): Promise<void> { | ||
| await this.client.rawQuery('PRAGMA writable_schema = 1;') | ||
| await this.client.rawQuery(`delete from sqlite_schema where type = 'view';`) | ||
| await this.client.rawQuery('PRAGMA writable_schema = 0;') | ||
| await this.client.rawQuery('VACUUM;') | ||
| } | ||
|
|
||
| /** | ||
| * Drop all custom types inside the database | ||
| */ | ||
| public async dropAllTypes(): Promise<void> { | ||
| throw new Error("Sqlite doesn't support types") | ||
| } | ||
|
|
||
| /** | ||
| * Attempts to add advisory lock to the database and | ||
| * returns it's status. | ||
| */ | ||
| public getAdvisoryLock(): Promise<boolean> { | ||
| throw new Error("Sqlite doesn't support advisory locks") | ||
| } | ||
|
|
||
| /** | ||
| * Releases the advisory lock | ||
| */ | ||
| public releaseAdvisoryLock(): Promise<boolean> { | ||
| throw new Error("Sqlite doesn't support advisory locks") | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.