require 'pg'
# 数据库连接配置
conn = PG.connect(
host: 'localhost',
port: 5432,
user: 'your_username',
password: 'your_password',
dbname: 'your_database'
)
# 构建SQL语句并防范SQL注入
sql = <<-SQL
SELECT c.customer_name, c.phone
FROM customers c
JOIN orders o ON c.customer_id = o.customer_id
JOIN order_items oi ON o.order_id = oi.order_id
WHERE o.order_date > '2023-01-01'
AND oi.quantity > 5
SQL
# 执行SQL查询
result = conn.exec(sql)
# 输出结果
result.each do |row|
puts "Customer Name: #{row['customer_name']}, Phone: #{row['phone']}"
end
# 关闭数据库连接
conn.close