RESTful API中SQLite数据库的接入问题求助

嘿，我刚帮几个新手解决过类似的问题，别担心，把REST API和SQLite对接其实没你想的那么复杂！核心逻辑很简单：API路由负责接收HTTP请求（比如获取用户列表、新增用户），在路由函数里调用数据库的增删改查操作，再把结果转成JSON格式返回给客户端就行。

我以你大概率用到的Python Flask框架为例，给你一步步拆解实操步骤：

1. 先封装SQLite数据库操作函数 #

先把基础的数据库操作（连接、查询、插入等）封装成工具函数，这样后面在API路由里调用会更清晰，也方便复用。

import sqlite3
from sqlite3 import Error

def create_connection(db_file):
    """创建SQLite数据库连接"""
    conn = None
    try:
        conn = sqlite3.connect(db_file)
        return conn
    except Error as e:
        print(e)
    return conn

def get_all_users(conn):
    """查询所有用户数据并转成字典格式"""
    cur = conn.cursor()
    cur.execute("SELECT * FROM users")
    rows = cur.fetchall()
    
    # 把SQLite返回的元组转成字典，方便后续转JSON
    users = []
    for row in rows:
        user = {
            "id": row[0],
            "name": row[1],
            "email": row[2]
        }
        users.append(user)
    return users

def create_user(conn, user):
    """插入新用户数据"""
    sql = ''' INSERT INTO users(name,email)
              VALUES(?,?) '''
    cur = conn.cursor()
    cur.execute(sql, user)
    conn.commit()
    return cur.lastrowid  # 返回新增用户的ID

注：这里假设你的SQLite数据库里有个users表，字段是id（主键自增）、name、email，你可以根据自己的表结构调整字段和SQL语句。

2. 在API路由里调用数据库函数 #

接下来把Flask的API路由和上面的数据库函数结合，完成请求处理→数据库操作→返回响应的流程：

from flask import Flask, jsonify, request

app = Flask(__name__)
DATABASE = "your_database.db"  # 替换成你自己的SQLite数据库文件路径

# 获取所有用户的API接口
@app.route('/users', methods=['GET'])
def get_users():
    conn = create_connection(DATABASE)
    if conn is None:
        return jsonify({"error": "无法连接数据库"}), 500
    
    users = get_all_users(conn)
    conn.close()  # 操作完一定要关闭连接
    return jsonify(users)

# 新增用户的API接口
@app.route('/users', methods=['POST'])
def add_user():
    new_user = request.get_json()
    # 校验请求参数是否完整
    if not new_user or 'name' not in new_user or 'email' not in new_user:
        return jsonify({"error": "缺少必要字段：name或email"}), 400
    
    conn = create_connection(DATABASE)
    if conn is None:
        return jsonify({"error": "无法连接数据库"}), 500
    
    user_id = create_user(conn, (new_user['name'], new_user['email']))
    conn.close()
    return jsonify({"id": user_id, "message": "用户创建成功"}), 201

if __name__ == '__main__':
    app.run(debug=True)

3. 关键注意事项 #

• 数据库连接要及时关闭：每次操作完数据库记得调用conn.close()，或者用with语句自动管理连接（比如with create_connection(DATABASE) as conn:），避免连接泄漏。
• 做好错误处理：要考虑数据库连接失败、请求参数缺失等异常情况，返回对应的HTTP状态码（比如500表示服务器内部错误，400表示请求参数错误），方便前端排查问题。
• 数据格式转换：SQLite查询返回的是元组，要转换成字典或列表格式，这样Flask的jsonify才能正常生成JSON响应。

如果你用的是Node.js/Express #

如果你的REST API教程用的是Node.js，核心逻辑完全一致，只是用sqlite3包操作数据库，示例代码如下：

const express = require('express');
const sqlite3 = require('sqlite3').verbose();
const app = express();
app.use(express.json());

// 连接SQLite数据库
const db = new sqlite3.Database('./your_database.db', (err) => {
  if (err) console.error(err.message);
  console.log('已连接到SQLite数据库');
});

// 获取所有用户接口
app.get('/users', (req, res) => {
  db.all('SELECT * FROM users', [], (err, rows) => {
    if (err) {
      res.status(500).json({ error: err.message });
      return;
    }
    res.json(rows);
  });
});

// 新增用户接口
app.post('/users', (req, res) => {
  const { name, email } = req.body;
  if (!name || !email) {
    res.status(400).json({ error: '缺少name或email字段' });
    return;
  }
  db.run('INSERT INTO users(name, email) VALUES(?, ?)', [name, email], function(err) {
    if (err) {
      res.status(500).json({ error: err.message });
      return;
    }
    res.status(201).json({ id: this.lastID, message: '用户创建成功' });
  });
});

app.listen(3000, () => console.log('服务器运行在端口3000'));

你可以先单独测试数据库函数是否能正常读写SQLite，再和API路由结合，分步调试更容易定位问题。

内容的提问来源于stack exchange，提问作者M. Gorski