checking connection for mssql

src/app.module.ts

@@ -2,9 +2,10 @@ import { Module } from '@nestjs/common';
 import { DbModule } from './db/db.module';
 import { OracleModule } from './oracle/oracle.module';
 import { AuthModule } from './auth/auth.module';
+import { MssqlModule } from './mssql/mssql.module';
 
 @Module({
-  imports: [AuthModule, DbModule, OracleModule],
+  imports: [MssqlModule, AuthModule, DbModule, OracleModule],
   controllers: [],
   providers: [],
 })

src/db/db.service.ts

@@ -31,7 +31,6 @@ export class MssqlDBService {
   private pool: ConnectionPool;
   private readonly config = {
     ...MssqlConfig,
-    server: 'localhost',
     pool: {
       max: 10,
       min: 0,

src/mssql/mssql.controller.ts

@@ -0,0 +1,15 @@
+import { Controller, Get } from '@nestjs/common';
+import { ApiTags } from '@nestjs/swagger';
+import { MssqlService } from './mssql.service';
+
+@Controller('mssql')
+export class MssqlController {
+
+    constructor(private readonly mssqlService:MssqlService){}
+
+    @ApiTags('Connection - Mssql')
+    @Get('/checkConnection')
+    checkConnection() {
+        return this.mssqlService.checkConnection();
+    }
+}

src/mssql/mssql.module.ts

@@ -0,0 +1,9 @@
+import { Module } from '@nestjs/common';
+import { MssqlController } from './mssql.controller';
+import { MssqlService } from './mssql.service';
+
+@Module({
+  controllers: [MssqlController],
+  providers: [MssqlService]
+})
+export class MssqlModule {}

src/mssql/mssql.service.ts

@@ -0,0 +1,34 @@
+import { Injectable } from '@nestjs/common';
+import { Request } from 'mssql';
+import { MssqlDBService } from 'src/db/db.service';
+
+@Injectable()
+export class MssqlService {
+
+    constructor(private readonly mssqlDBService: MssqlDBService) { }
+
+    async checkConnection() {
+        let connection;
+
+        try {
+            connection = await this.mssqlDBService.getConnection();
+
+            // Create a new Request object
+            const request = new Request(connection);
+
+            // Execute the query
+            const result = await request.query('SELECT GETDATE() AS CurrentDateTime');
+
+            console.log("Connection successful. Current date and time from the server:");
+            console.log(result.recordset[0].CurrentDateTime);
+            return { data: result.recordset[0].CurrentDateTime }
+
+        } catch (error) {
+            console.error('Error checking connection:', error);
+        } finally {
+            if (connection) {
+                connection.close(); // Ensure the connection is closed
+            }
+        }
+    }
+}