Express.js Integration

npm install query-2jz @query-2jz/express

const express = require('express')
const { query-2jzExpress } = require('@query-2jz/express')
const query-2jz = require('query-2jz')

const app = express()

// Initialize Query-2jz
const query-2jzInstance = query-2jz({
  database: {
    type: 'postgresql',
    url: process.env.DATABASE_URL
  }
})

// Define your models
const User = query-2jzInstance.model('User', {
  id: { type: 'string', primary: true },
  name: { type: 'string', required: true },
  email: { type: 'string', required: true, unique: true }
})

// Mount Query-2jz API routes
app.use('/api', query-2jzExpress(query-2jzInstance))

app.listen(3000, () => {
  console.log('Server running on http://localhost:3000')
})

const express = require('express')
const { query-2jzExpress } = require('@query-2jz/express')
const query-2jz = require('query-2jz')

const app = express()

// Add middleware before Query-2jz
app.use('/api', (req, res, next) => {
  // Authentication middleware
  if (!req.headers.authorization) {
    return res.status(401).json({ error: 'Unauthorized' })
  }
  next()
})

// Add logging middleware
app.use('/api', (req, res, next) => {
  console.log(`${req.method} ${req.path}`)
  next()
})

// Initialize Query-2jz with custom options
const query-2jzInstance = query-2jz({
  database: {
    type: 'postgresql',
    url: process.env.DATABASE_URL
  },
  cache: {
    type: 'redis',
    url: process.env.REDIS_URL
  },
  realtime: {
    enabled: true,
    transport: 'websocket'
  }
})

// Mount with custom configuration
app.use('/api', query-2jzExpress(query-2jzInstance, {
  prefix: '/query-2jz',
  cors: true,
  rateLimit: {
    windowMs: 15 * 60 * 1000, // 15 minutes
    max: 100 // limit each IP to 100 requests per windowMs
  }
}))

// Custom error handler for Query-2jz routes
app.use('/api', (err, req, res, next) => {
  if (err.name === 'ValidationError') {
    return res.status(400).json({
      error: 'Validation failed',
      details: err.details
    })
  }
  
  if (err.name === 'NotFoundError') {
    return res.status(404).json({
      error: 'Resource not found'
    })
  }
  
  // Log unexpected errors
  console.error('Query-2jz Error:', err)
  res.status(500).json({
    error: 'Internal server error'
  })
})

// Health check endpoint
app.get('/health', (req, res) => {
  res.json({ 
    status: 'ok', 
    query-2jz: query-2jzInstance.isConnected() 
  })
})