typeorm db

Author: mostafa6765

package.json

@@ -20,8 +20,10 @@
     "test:cov": "jest --coverage",
     "test:debug": "node --inspect-brk -r tsconfig-paths/register -r ts-node/register node_modules/.bin/jest --runInBand",
     "test:e2e": "jest --config ./test/jest-e2e.json",
-    "typeorm": "typeorm-ts-node-commonjs -d ./src/setup/db/data-source.ts",
-    "migration:generate": "npm run typeorm migration:generate"
+    "typeorm": "typeorm-ts-node-commonjs",
+    "typeorm:source": "typeorm-ts-node-commonjs -d ./src/setup/db/data-source.ts",
+    "migration:generate": "yarn typeorm:source migration:generate",
+    "migration:run": "yarn typeorm:source migration:run"
   },
   "dependencies": {
     "@nestjs/common": "^9.0.0",

src/core/app.module.ts

@@ -7,7 +7,6 @@ import EmailScheduleService from '@kitApp/schedule/email.schedule.service';
 import databaseConfig from '@kitConfig/database.config';
 import { database } from '@kitSetup/index';
 import { DataSource } from 'typeorm';
-import { TypeOrmModule } from '@nestjs/typeorm';
 import { AppController } from './app.controller';
 import { AppService } from './app.service';
 

src/db/migrations/.gitkeeep

@@ -0,0 +1,30 @@
+import { MigrationInterface, QueryRunner, Table } from 'typeorm';
+
+export class createUsersTable1673884759250 implements MigrationInterface {
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.createTable(
+      new Table({
+        name: 'users',
+        columns: [
+          {
+            name: 'id',
+            type: 'int',
+            isPrimary: true,
+            isGenerated: true,
+          },
+          {
+            name: 'firstName',
+            type: 'varchar',
+          },
+          {
+            name: 'lastName',
+            type: 'varchar',
+          },
+        ],
+      }),
+    );
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+  }
+}

src/db/migrations/1673884759250-create-users-table.ts

@@ -0,0 +1,5 @@
+# command
+
+```
+yarn typeorm migration:create ./src/db/migrations/create_xyz_table
+```

src/db/migrations/README.md

@@ -0,0 +1,15 @@
+import {
+  Entity, Column, PrimaryGeneratedColumn, PrimaryColumn,
+} from 'typeorm';
+
+@Entity({ name: 'users' })
+export class User {
+  @PrimaryColumn()
+    id: number;
+
+  @Column()
+    firstName: string;
+
+  @Column()
+    lastName: string;
+}

src/modules/user/user.entity.ts

@@ -1,10 +1,13 @@
 import { Module } from '@nestjs/common';
+import { TypeOrmModule } from '@nestjs/typeorm';
 import { UserController } from './user.controller';
 import { UserService } from './user.service';
+import { User } from './user.entity';
 
 @Module({
-  imports: [],
+  imports: [TypeOrmModule.forFeature([User])],
   controllers: [UserController],
   providers: [UserService],
+  exports: [TypeOrmModule],
 })
 export class UserModule {}

src/modules/user/user.module.ts

@@ -1,16 +1,35 @@
-import { Injectable, UnprocessableEntityException } from '@nestjs/common';
+import { Injectable, NotFoundException, UnprocessableEntityException } from '@nestjs/common';
+import { InjectRepository } from '@nestjs/typeorm';
+import { randomInt } from 'crypto';
+import { Repository } from 'typeorm';
+import { User } from './user.entity';
 
 @Injectable()
 export class UserService {
-  getHello(): any {
+  constructor(
+    @InjectRepository(User) private usersRepository: Repository<User>,
+  ) { }
+
+  async getHello() {
+    try {
+      await this.usersRepository
+        .createQueryBuilder()
+        .insert()
+        .into(User)
+        .values([
+          { firstName: 'kamal', lastName: 'mostafa' },
+        ])
+        .returning('id')
+        .execute();
+    } catch (error) {
+      return error;
+    }
+
     try {
-      let output: any = {
-        project: 'nestjs',
-      };
-      return output;
+      let a = await this.usersRepository.find();
+      return a;
     } catch (error) {
-      let data: any = [{ error: [{ a: 22 }] }];
-      throw new UnprocessableEntityException(data);
+      return error;
     }
   }
 }

src/modules/user/user.service.ts

@@ -9,7 +9,6 @@ declare let process : {
 dotenv.config();
 
 export const dataSource = new DataSource({
-  migrationsTableName: 'migrations',
   type: process.env.DB_TYPE || '',
   host: process.env.DB_HOST || '',
   port: process.env.DB_PORT || 5432,
@@ -18,6 +17,7 @@ export const dataSource = new DataSource({
   database: process.env.DB_DATABASE || '',
   synchronize: false,
   logging: false,
+  migrationsTableName: 'nestjs_kit_migrations',
   entities: ['src/**/*.entity.ts'],
   migrations: ['src/db/migrations/*.ts'],
 });