nmchenry01

const executeTransaction = async () => {
  await getManager().transaction(async (transactionalEntityManager) => {
    const customerRepository = transactionalEntityManager.getRepository(
      Customer,
    );
    const companyRepository = transactionalEntityManager.getRepository(Company);

    const umbrella = companyRepository.create({ name: 'Umbrella' });
    await companyRepository.save(umbrella);

nmchenry01

const experimentalTransaction = async (prisma: PrismaClient) => {
  const createCompany = prisma.company.create({ data: { name: 'Umbrella' } });

  const createCustomer = prisma.customer.create({
    data: { username: 'User5', email: 'User5@gmail.com' },
  });

  return prisma.transaction([createCompany, createUser]);
};

nmchenry01

const deleteCustomer = async () => {
  const customerRepository = getRepository(Customer);

  return customerRepository.delete({ username: 'User4' });
};

nmchenry01

const updateProductDescription = async () => {
  const productRepository = getRepository(Product);

  return productRepository.update(
    { name: 'Printer' },
    { description: 'It works sometimes' },
  );
};

nmchenry01

const updateProductDescription = async (prisma: PrismaClient) => {
  return prisma.product.update({
    where: {
      name: 'Printer',
    },
    data: {
      description: 'It works sometimes',
    },
  });
};

nmchenry01

const findCompaniesThatMakeCarsOrDynamite = async () => {
  const companyRepository = getRepository(Company);

  return companyRepository
    .createQueryBuilder('company')
    .innerJoinAndSelect('company.products', 'product')
    .andWhere('product.name IN (:...names)', { names: ['Car', 'Dynamite'] })
    .getMany();
};

nmchenry01

const findCustomersForCompany = () => {
  const customerRepository = getRepository(Customer);

  return customerRepository
    .createQueryBuilder('customer')
    .innerJoinAndSelect('customer.products', 'products')
    .innerJoinAndSelect('products.company', 'company')
    .andWhere('company.name = :name', { name: 'Acme' })
    .select('customer.username')
    .orderBy('customer.username', 'DESC')

nmchenry01

const findCompanyByName = async () => {
  const companyRepository = getRepository(Company);

  return companyRepository.findOne({ where: { name: 'Globex' } });
};

nmchenry01

export const createCustomer = async () => {
  const customerRepository = getRepository(Customer);
  const productRepository = getRepository(Product);

  const dynamite = await productRepository.findOne({
    where: { name: 'Dynamite' },
  });
  const car = await productRepository.findOne({
    where: {
      name: 'Car',

nmchenry01

const createProduct = async () => {
  const productRepository = getRepository(Product);
  const companyRepository = getRepository(Company);

  const acme = await companyRepository.findOne({ where: { name: 'Acme' } });
  
  const dynamite = productRepository.create({
    name: 'Dynamite',
    description: 'It goes "boom"',
    company: acme,