Pular para o conteúdo

JavaScript / TypeScript

Terminal window
npm install @petradb/engine

Cria uma nova instancia de banco de dados.

OpcaoTipoPadraoDescricao
rowMode'object' | 'array''object'Formato padrao de linha para resultados SELECT
storage'memory' | 'persistent' | 'text''memory'Backend de armazenamento
pathstringCaminho do arquivo (obrigatorio para persistente e texto)
pageSizenumber4096Tamanho da pagina em bytes (apenas persistente)
// Em memoria (padrao)
const db = new Session();
// Armazenamento persistente seguro contra falhas (Node.js)
const db = new Session({ storage: 'persistent', path: './mydb' });
// Arquivo de texto legivel por humanos (Node.js)
const db = new Session({ storage: 'text', path: './data.ptxt' });

Para armazenamento persistente, o PetraDB detecta automaticamente se deve criar um novo arquivo ou abrir um existente.

Libera handles de arquivo. Retorna Promise<void>. Obrigatorio para armazenamento persistente e de texto. Sem efeito (mas ainda assincrono) para bancos em memoria.

await db.close();

Executa um ou mais comandos SQL separados por ;. Retorna uma promise que resolve para um array de resultados.

OpcaoTipoPadraoDescricao
rowMode'object' | 'array'padrao do construtorFormato de linha para esta chamada
const [{ rows, fields }] = await db.execute('SELECT * FROM users');

Cria um prepared statement com placeholders de parametro $1, $2, … Retorna um objeto statement com um metodo execute(params, options?).

const stmt = db.prepare('SELECT * FROM users WHERE id = $1');
const [{ rows }] = await stmt.execute([42]);
// Com opcoes
const [{ rows }] = await stmt.execute([42], { rowMode: 'array' });

Registra uma funcao JavaScript nativa chamavel a partir de SQL, triggers e stored procedures:

db.registerFunction('my_double', (args) => args[0] * 2);
// Agora utilizavel em SQL:
const [{ rows }] = await db.execute('SELECT my_double(21) AS val');
// rows[0].val === 42

O callback recebe um array de valores JavaScript (numeros, strings, booleanos ou null) e deve retornar um valor JavaScript.

interface SessionOptions {
rowMode?: 'object' | 'array';
storage?: 'memory' | 'persistent' | 'text';
path?: string;
pageSize?: number;
}
interface ExecuteOptions {
rowMode?: 'object' | 'array';
}
interface PreparedStatement {
execute(params?: any[], options?: ExecuteOptions): Promise<ExecuteResult[]>
}
class Session {
constructor(options?: SessionOptions)
execute(sql: string, options?: ExecuteOptions): Promise<ExecuteResult[]>
prepare(sql: string): PreparedStatement
close(): Promise<void>
}

Todo resultado tem um campo command para discriminacao:

// DDL
{ command: 'create table', table: string }
{ command: 'drop table', table: string }
{ command: 'create type', type: string }
{ command: 'drop type', type: string }
{ command: 'create index', index: string }
{ command: 'drop index', index: string }
{ command: 'truncate table', table: string }
{ command: 'alter table' }
{ command: 'create view', view: string }
{ command: 'drop view', view: string }
{ command: 'create sequence', sequence: string }
{ command: 'drop sequence', sequence: string }
{ command: 'create schema', schema: string }
{ command: 'create trigger', trigger: string }
{ command: 'drop trigger', trigger: string }
// PL/pgSQL
{ command: 'do' }
{ command: 'create function', function: string }
{ command: 'drop function', function: string }
{ command: 'create procedure', procedure: string }
{ command: 'drop procedure', procedure: string }
{ command: 'call' }
// Plano de consulta
{ command: 'explain', plan: string }
// DML
{ command: 'insert', result: Record<string, any>, rows: T[], fields: FieldInfo[] }
{ command: 'select', rows: T[], fields: { name: string, dataType: string }[] }
{ command: 'update', rowCount: number }
{ command: 'delete', rowCount: number }
{ command: 'copy', rowCount: number }
// Transacoes
{ command: 'begin' }
{ command: 'commit' }
{ command: 'rollback' }
// Prepared statements
{ command: 'prepare', name: string }
{ command: 'deallocate', name: string }
Tipo SQLTipo JavaScript
INT, BIGINT, DOUBLE, NUMERICnumber
TEXT, CHAR, VARCHARstring
BOOLEANboolean
UUIDstring
TIMESTAMPDate
ENUMstring (rotulo)
JSON arrayArray
JSON objectObject
NULLnull