Repository Methods - create(), update(), delete()

create()

Create a new record in the table. Automatically returns the full created record including ID and timestamps.

Basic Usage

const result = await $ctx.$repos.products.create({
  data: {
    name: 'New Product',
    price: 99.99,
    category: 'electronics'
  }
});

const newProduct = result.data[0];  // Full product record with ID, timestamps, etc.

Parameters

await $ctx.$repos.tableName.create({
  data: { ... },       // Data to insert (required)
  fields: '...'        // Fields to return (optional)
})

Creating Records

Simple create

const result = await $ctx.$repos.products.create({
  data: {
    name: 'iPhone 15',
    price: 999,
    category: 'electronics'
  }
});

Create with all fields

const result = await $ctx.$repos.products.create({
  data: {
    name: 'iPhone 15',
    price: 999,
    category: 'electronics',
    description: 'Latest iPhone model',
    isActive: true,
    stock: 50
  }
});

Return specific fields after create

const result = await $ctx.$repos.products.create({
  data: {
    name: 'iPhone 15',
    price: 999
  },
  fields: 'id,name,price'  // Only return these fields
});

Important Notes

1. ID is auto-generated: Never include id in the data object - it will be automatically generated by the database
2. Timestamps are auto-generated: createdAt and updatedAt are automatically added by the system
3. Full record is returned: The method automatically calls find() after insertion to return the complete record
4. Validation happens automatically: System validates table schema and system protection rules

Create with Relations

// Create order with related items
const orderResult = await $ctx.$repos.orders.create({
  data: {
    customerId: 123,
    total: 299.99,
    status: 'pending'
  }
});

const order = orderResult.data[0];

// Create order items
const itemResult = await $ctx.$repos.order_items.create({
  data: {
    orderId: order.id,
    productId: 456,
    quantity: 2,
    price: 149.99
  }
});

Error Handling

try {
  const result = await $ctx.$repos.products.create({
    data: {
      name: 'Product Name',
      price: 99.99
    }
  });
} catch (error) {
  // Handle validation errors, constraint violations, etc.
  $ctx.$logs(`Failed to create product: ${error.message}`);
}

---

update()

Update an existing record by ID. Automatically returns the full updated record.

Basic Usage

const result = await $ctx.$repos.products.update({
  id: 123,
  data: {
    price: 89.99,
    isOnSale: true
  }
});

const updatedProduct = result.data[0];  // Full updated product record

Parameters

await $ctx.$repos.tableName.update({
  id: 123,              // Record ID to update (required)
  data: { ... },        // Fields to update (required)
  fields: '...'         // Fields to return (optional)
})

Updating Records

Update single field

const result = await $ctx.$repos.products.update({
  id: 123,
  data: {
    price: 89.99
  }
});

Update multiple fields

const result = await $ctx.$repos.products.update({
  id: 123,
  data: {
    price: 89.99,
    isOnSale: true,
    description: 'Updated description'
  }
});

Return specific fields after update

const result = await $ctx.$repos.products.update({
  id: 123,
  data: {
    price: 89.99
  },
  fields: 'id,name,price'  // Only return these fields
});

Important Notes

1. ID must exist: The record with the given ID must exist, otherwise an error is thrown
2. Partial updates: You only need to include fields you want to update
3. Full record is returned: The method automatically calls find() after update to return the complete record
4. Timestamps are auto-updated: updatedAt is automatically updated by the system
5. Validation happens automatically: System validates table schema and system protection rules

Check if Record Exists First

// Find the record first
const findResult = await $ctx.$repos.products.find({
  where: { id: { _eq: 123 } }
});

if (findResult.data.length === 0) {
  $ctx.$throw['404']('Product not found');
  return;
}

// Update the record
const result = await $ctx.$repos.products.update({
  id: 123,
  data: {
    price: 89.99
  }
});

Error Handling

try {
  const result = await $ctx.$repos.products.update({
    id: 123,
    data: {
      price: 89.99
    }
  });
} catch (error) {
  // Handle errors: record not found, validation errors, etc.
  $ctx.$logs(`Failed to update product: ${error.message}`);
}

---

delete()

Delete a record by ID. Returns a success message.

Basic Usage

const result = await $ctx.$repos.products.delete({
  id: 123
});

// result: { message: 'Delete successfully!', statusCode: 200 }

Parameters

await $ctx.$repos.tableName.delete({
  id: 123  // Record ID to delete (required)
})

Deleting Records

Simple delete

const result = await $ctx.$repos.products.delete({
  id: 123
});

Check if record exists before deleting

// Find the record first
const findResult = await $ctx.$repos.products.find({
  where: { id: { _eq: 123 } }
});

if (findResult.data.length === 0) {
  $ctx.$throw['404']('Product not found');
  return;
}

// Delete the record
const result = await $ctx.$repos.products.delete({
  id: 123
});

Important Notes

1. ID must exist: The record with the given ID must exist, otherwise an error is thrown
2. Cascade behavior: If the table has relations with onDelete: 'cascade', related records will be deleted automatically
3. Returns success message: The method returns { message: 'Delete successfully!', statusCode: 200 }
4. Cannot be undone: Deletion is permanent - make sure to validate before deleting

Error Handling

try {
  const result = await $ctx.$repos.products.delete({
    id: 123
  });
} catch (error) {
  // Handle errors: record not found, constraint violations, etc.
  $ctx.$logs(`Failed to delete product: ${error.message}`);
}

Next Steps

• See find() method for querying records
• Learn about Common Patterns for best practices
• Check Error Handling for proper error handling