forked from Dongjiaqi/reposync
70 lines
2.2 KiB
Python
70 lines
2.2 KiB
Python
import urllib
|
||
import requests
|
||
import mysql.connector
|
||
|
||
# 连接到MySQL数据库
|
||
conn = mysql.connector.connect(
|
||
host="localhost",
|
||
user="root",
|
||
password="185102xmy",
|
||
database="db1"
|
||
)
|
||
cursor = conn.cursor()
|
||
# cursor.execute('DROP TABLE IF EXISTS gitee_pr_list')
|
||
# # 创建一个表
|
||
# cursor.execute('''CREATE TABLE IF NOT EXISTS gitee_pr_list
|
||
# (id INT AUTO_INCREMENT PRIMARY KEY, number VARCHAR(10), state VARCHAR(15), title VARCHAR(100), body VARCHAR(1000), head VARCHAR(15), base VARCHAR(15))''')
|
||
# 你的仓库信息
|
||
owner = 'xumingyang21'
|
||
repo = 'reposyncer2'
|
||
number = 3
|
||
# Gitee获取issue的API URL
|
||
url = f'https://gitee.com/api/v5/repos/{owner}/{repo}/pulls/{number}'
|
||
|
||
# 构造请求头
|
||
token = 'f2be2313581c1fde50b16bf35bb655c5'
|
||
headers = {'Authorization': f'token {token}'}
|
||
|
||
# 发送POST请求 获取状态为open的issue
|
||
data = {
|
||
"access_token":token,
|
||
"owner":owner,
|
||
"repo":repo,
|
||
"title":'尝试更改pr',
|
||
"body":'好冲',
|
||
"state":'closed'
|
||
}
|
||
|
||
# 将字典转换为查询字符串
|
||
query_string = urllib.parse.urlencode(data)
|
||
# 完整的请求 URL，包括查询字符串
|
||
full_url = f"{url}?{query_string}"
|
||
response = requests.patch(full_url, headers=headers, json=data)
|
||
# 打印响应
|
||
# print(response.text)
|
||
# 检查响应状态码
|
||
if response.status_code == 200:
|
||
# 注意：这里假设响应体中包含一个'number'字段作为issue的ID，但实际上Gitee可能返回不同的结构
|
||
# 你需要根据实际的响应结构来调整以下代码
|
||
pr_info = response.json()
|
||
print(pr_info)
|
||
# for pr in pr_info:
|
||
# print('number:',pr['id'])
|
||
# print('state:',pr['state'])
|
||
# print('title:',pr['title'])
|
||
# print('body:',pr['body'])
|
||
# print('head:',pr['head']['label'])
|
||
# print('base:',pr['base']['label'])
|
||
# cursor.execute('INSERT INTO gitee_pr_list (number, state, title, body, head, base) VALUES (%s, %s, %s, %s, %s, %s)',
|
||
# (pr['id'], pr['state'], pr['title'], pr['body'], pr['head']['label'], pr['base']['label']))
|
||
|
||
else:
|
||
print(f"获取pr失败，状态码：{response.status_code}，错误信息：{response.text}")
|
||
|
||
# 提交事务
|
||
conn.commit()
|
||
# 关闭游标和连接
|
||
cursor.close()
|
||
conn.close()
|
||
|