import 'reflect-metadata';
import {
	createTestingConnections,
	closeTestingConnections,
	reloadTestingDatabases,
} from '../../utils/test-utils';
import { DataSource } from '../../../src/data-source/DataSource';
import { expect } from 'chai';
import { User } from './entity/User';

describe('github issues > #3047 Mysqsl on duplicate key update use current values', () => {
	let connections: DataSource[];

	before(
		async () =>
			(connections = await createTestingConnections({
				entities: [User],
				schemaCreate: true,
				dropSchema: true,
			})),
	);

	beforeEach(() => reloadTestingDatabases(connections));

	after(() => closeTestingConnections(connections));

	let user1 = new User();
	user1.first_name = 'John';
	user1.last_name = 'Lenon';
	user1.is_updated = 'no';

	let user2 = new User();
	user2.first_name = 'John';
	user2.last_name = 'Lenon';
	user2.is_updated = 'yes';

	it('should overwrite using current value in MySQL/MariaDB', () =>
		Promise.all(
			connections.map(async (connection) => {
				try {
				} catch (err) {
					throw new Error(err);
				}
			}),
		));

	it('should overwrite using current value in PostgreSQL', () =>
		Promise.all(
			connections.map(async (connection) => {
				try {
					if (connection.driver.options.type === 'postgres') {
						const UserRepository = connection.manager.getRepository(User);

						await UserRepository.createQueryBuilder().insert().into(User).values(user1).execute();

						await UserRepository.createQueryBuilder()
							.insert()
							.into(User)
							.values(user2)
							.orUpdate(['is_updated'], ['first_name', 'last_name'])
							.execute();

						let loadedUser = await UserRepository.find();
						expect(loadedUser).not.to.be.null;
						expect(loadedUser).to.have.lengthOf(1);
						expect(loadedUser[0]).to.includes({ is_updated: 'yes' });
					}
				} catch (err) {
					throw new Error(err);
				}
			}),
		));
});