PostgreSQL

PostgreSQL raw connector

Examples:

import { inject, container, Types, Core } from '@biorate/inversion';
import { IConfig, Config } from '@biorate/config';
import { PgConnector, IPgConnector } from '@biorate/pg';

class Root extends Core() {
  @inject(PgConnector) public connector: IPgConnector;
}

container.bind<IConfig>(Types.Config).to(Config).inSingletonScope();
container.bind<IPgConnector>(PgConnector).toSelf().inSingletonScope();
container.bind<Root>(Root).toSelf().inSingletonScope();

container.get<IConfig>(Types.Config).merge({
  Pg: [
    {
      name: 'connection',
      options: {
        user: 'postgres',
        host: 'localhost',
        database: 'postgres',
        password: 'postgres',
        port: 5432,
      },
    },
  ],
});

(async () => {
  const root = container.get<Root>(Root);
  await root.$run();
  await root.connector!.current?.query(
    `CREATE TABLE test (
         count int,
         text varchar(20)
      );`,
  );
  await root.connector!.current?.query(
    `INSERT INTO test (count, text) VALUES (1, 'test1'), (2, 'test2'), (3, 'test3');`,
  );
  console.log((await root.connector!.current?.query(`SELECT * FROM test;`))!.rows);
  // [
  //   {
  //     "count": 1,
  //     "text": "test1",
  //   },
  //   {
  //     "count": 2,
  //     "text": "test2",
  //   },
  //   {
  //     "count": 3,
  //     "text": "test3",
  //   },
  // ]
})();

Learn

• Documentation can be found here - docs.

Release History

See the CHANGELOG

License

MIT

Copyright (c) 2021-present Leonid Levkin (llevkin)