Database Ops - 数据库操作\r

\r

SQLite/MySQL数据库直接操作，支持查询/更新/备份\r 最后更新：2026-04-13\r \r ---\r \r

功能概述\r

\r

• 📊 查询数据：SQL查询执行\r
• 🔧 数据维护：增删改数据\r
• 💾 备份恢复：数据库备份\r
• 📈 统计分析：数据统计分析\r \r ---\r \r

支持的数据库\r

\r

SQLite（本地）\r

路径：\r
- data/stock_profiles.db\r
- data/commodity_options.db\r
- data/financial_data.db\r
- lottery_v3.db\r
```\r
\r
### MySQL（远程）\r
```\r
待配置：\r
- Host: localhost\r
- Port: 3306\r
```\r
\r
---\r
\r
## 核心命令\r
\r
### 1. 查询\r
```\r
命令：db查询 [SQL]\r
\r
示例：\r
- db查询 SELECT * FROM stocks LIMIT 10\r
- db查询 SELECT code, name FROM stocks WHERE price > 100\r
```\r
\r
### 2. 统计\r
```\r
命令：db统计 [表名]\r
\r
示例：\r
- db统计 stock_profiles\r
- db统计 odds_history\r
```\r
\r
### 3. 备份\r
```\r
命令：db备份 [数据库]\r
\r
示例：\r
- db备份 stock_profiles\r
- db备份 all\r
```\r
\r
### 4. 表结构\r
```\r
命令：db结构 [表名]\r
\r
示例：\r
- db结构 stocks\r
- db结构 odds_history\r
```\r
\r
---\r
\r
## 常用查询模板\r
\r
### 股票数据\r
```sql\r
-- 最近采集的股票\r
SELECT code, name, price, change_pct \r
FROM stocks \r
ORDER BY update_time DESC LIMIT 10\r
\r
-- 涨跌幅排行\r
SELECT code, name, change_pct \r
FROM stocks \r
ORDER BY change_pct DESC LIMIT 10\r
```\r
\r
### 竞彩数据\r
```sql\r
-- 最近的推荐\r
SELECT league, home_team, away_team, prediction, odds \r
FROM odds_history \r
ORDER BY created_at DESC LIMIT 10\r
\r
-- 命中率统计\r
SELECT league, COUNT(*) as total, \r
       SUM(CASE WHEN result = 'win' THEN 1 ELSE 0 END) as wins\r
FROM odds_history GROUP BY league\r
```\r
\r
---\r
\r
## 注意事项\r
\r
- 写操作需谨慎，建议先备份\r
- 敏感数据查询需脱敏\r
- 定期备份重要数据\r
- 大数据量查询注意性能\r
\r
\r
## Code Implementation\r
\r
Python实现: database_ops.py\r
\r
`python\r
from database_ops import DatabaseOps, sqlite_query\r
\r
# 创建连接\r
db = DatabaseOps('data.db')\r
\r
# 查询\r
results = db.execute('SELECT * FROM stocks LIMIT 10')\r
\r
# 插入\r
db.insert('stocks', {'code': '000001', 'name': 'Test', 'price': 10.0})\r
\r
# 批量插入\r
db.insert_many('stocks', [{'code': '1', 'price': 10}, {'code': '2', 'price': 20}])\r
\r
# 统计\r
count = db.count('stocks')\r
stats = db.stats('stocks')\r
\r
# 备份\r
backup_path = db.backup('backup.db')\r
\r
db.close()\r
\r
# 快速查询\r
results = sqlite_query('data.db', 'SELECT * FROM stocks')\r
`\r