Обработка базы данных при обращении к TypeORM - PullRequest
Новая
       8

Обработка базы данных при обращении к TypeORM

5 голосов
/ 16 января 2020

Допустим, произошел сбой моего сервера MS SQL, и мой клиент приложения запросил что-то из API. Прямо сейчас он будет просто вращаться до тех пор, пока время ожидания неотвеченного запроса не будет превышено на Express.

Когда в TypeORM включено ведение журнала, я вижу, что соответствующий запрос выполняется.

Я бы предпочел вернуть ответ API, информирующий клиента о том, что база данных недоступна.

Это фактический код в моем контроллере пользователя. 

public static listAll = async (req: Request, res: Response) => {
    const userRepository = getRepository(User);
    const users = await userRepository
        .find()
    res.send(users);
};

Я пытался поймать запрос, который используется в соответствующий контроллер, но, похоже, ничего не меняет. См. Пример ниже. 

const users = await userRepository
    .find()
    .catch(error => {
        console.log(error); // this is never triggered
});

В консоли не выводится сообщение об ошибке.

Это мои параметры подключения в TypeORM 

createConnection({
    type: 'mssql',
    host: process.env.TYPEORM_HOST,
    port: parseInt(process.env.TYPEORM_PORT, 0),
    username: process.env.TYPEORM_USERNAME,
    password: process.env.TYPEORM_PASSWORD,
    database: process.env.TYPEORM_DATABASE,
    synchronize: true,
    logging: true,
    entities: models,
    cli: {
        entitiesDir: 'src/entity',
        migrationsDir: 'src/migration',
        subscribersDir: 'src/subscriber',
    },
})
    .then(connection => {
        const server = http.createServer(App);
        server.listen({ port: `${process.env.APP_PORT}` }, () => {
            console.log(`? Server ready at http://${process.env.TYPEORM_HOST}:${process.env.APP_PORT}`);
        });

        if (connection.isConnected) {
            console.log(`Database ${connection.options.database} connected`);
        }
    })
    .catch(error => console.log(error));

Я также пытался установить requestTimeout в createConnection до 1000 (мс), с тем же результатом.

1 Ответ

0 голосов
/ 20 января 2020 
export default class App {

  public app:     express.Application;
  public db:      Connection;


  constructor() {
    this.app = express();
    this.appConfiguration();
  }

  public async appConfiguration() {

    try {
      this.db = await Database.init();

      // Make use of JSON Body
      this.app.use(bodyParser.json());

      // Inits Routes
      Routes.init(this.app);
    } catch(err) {
      console.log('database is not reachable, see error:', err)
    };

  }

  public getApp(): express.Application {
    return this.app;
  }

}

Database.init () используется для создания соединения с БД: 

export class Database {

  public static init() {

    return createConnection({
      type: "postgres",
      host: process.env.TYPEORM_HOST,
      port: parseInt(process.env.TYPEORM_PORT),
      database: process.env.TYPEORM_DATABASE,
      username: process.env.TYPEORM_USERNAME,
      password: process.env.TYPEORM_PASSWORD,
      entities: [
        User
      ],
      synchronize: process.env.TYPEORM_SYNCHRONIZE == "true" ? true : false,
      logging: process.env.TYPEORM_LOGGING == "true" ? true : false
    });

  }

}

Результат при изменении имени БД на некоторую случайную БД Я получу сообщения об ошибках в консоли: 

    [nodemon] starting `ts-node src/server.ts`
Server listening on port 5000
database is not reachable, see error:
{ error: database "express_text_typeorms" does not exist
    at Connection.parseE 
    at Connection.parseMessage 
    at Socket.<anonymous> 
    at Socket.emit (events.js:198:13)
    at Socket.EventEmitter.emit (domain.js:448:20)
    at addChunk (_stream_readable.js:288:12)
    at readableAddChunk (_stream_readable.js:269:11)
    at Socket.Readable.push (_stream_readable.js:224:10)
    at TCP.onStreamRead [as onread] (internal/stream_base_commons.js:94:17)
  name: 'error',
  length: 106,
  severity: 'FATAL',
  code: '3D000',
  detail: undefined,
  hint: undefined,
  position: undefined,
  internalPosition: undefined,
  internalQuery: undefined,
  where: undefined,
  schema: undefined,
  table: undefined,
  column: undefined,
  dataType: undefined,
  constraint: undefined,
  file: 'postinit.c',
  line: '890',
  routine: 'InitPostgres' }

Это то, что вы пытаетесь достичь?

...