connection-manager.test.js 1.4 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546
  1. 'use strict';
  2. const chai = require('chai');
  3. const expect = chai.expect;
  4. const Support = require('../../support');
  5. const dialect = Support.getTestDialect();
  6. const { DataTypes } = require('@sequelize/core');
  7. if (dialect === 'snowflake') {
  8. describe('[SNOWFLAKE Specific] Connection Manager', () => {
  9. it('-FOUND_ROWS can be suppressed to get back legacy behavior', async () => {
  10. const sequelize = Support.createSingleTestSequelizeInstance();
  11. const User = sequelize.define('User', { username: DataTypes.STRING });
  12. await User.sync({ force: true });
  13. await User.create({ id: 1, username: 'jozef' });
  14. const [affectedCount] = await User.update(
  15. { username: 'jozef' },
  16. {
  17. where: {
  18. id: 1,
  19. },
  20. },
  21. );
  22. // https://github.com/sequelize/sequelize/issues/7184
  23. await affectedCount.should.equal(1);
  24. });
  25. it('should acquire a valid connection when keepDefaultTimezone is true', async () => {
  26. const sequelize = Support.createSingleTestSequelizeInstance({
  27. keepDefaultTimezone: true,
  28. pool: { min: 1, max: 1, handleDisconnects: true, idle: 5000 },
  29. });
  30. await sequelize.sync();
  31. const connection = await sequelize.pool.acquire();
  32. expect(sequelize.dialect.connectionManager.validate(connection)).to.be.ok;
  33. sequelize.pool.release(connection);
  34. });
  35. });
  36. }