期货日数据维护与使用_日数据维护_sqlite3数据库创建

news2024/11/20 9:18:15

目录

写在前面：

初始准备

开始编写数据库代码

t_product 

t_symbol_basemsg

t_main_symbol

t_online_symbol

t_last30_daily

小贴士

写在前面：

本文默认已经创建了项目，如果不知道如何创建一个空项目的，请参看以下两篇博文

PyQt5将项目搬到一个新的虚拟环境中
https://blog.csdn.net/m0_37967652/article/details/122625280
python_PyQt5开发工具结构基础
https://blog.csdn.net/m0_37967652/article/details/131969032

初始准备

python自带有sqlite3的包，如果没有的话，自己安装下

pip install sqlite3 -i https://pypi.tuna.tsinghua.edu.cn/simple

创建一个py文件，命名为 sqlite_tool.py（文件名大家自行定义，只要后面使用能找到就行）

将数据库路径定义为一个常量

YOUKUANG_DB_NAME = 【项目路径】+‘youkuang_db.db’

开始编写数据库代码

t_product 

def create_product_table():
    conn = sqlite3.connect(YOUKUANG_DB_NAME)
    c = conn.cursor()
    c.execute('''
    create table if not exists t_product 
    (code text, name text,exchange_name text)
    ''')
    conn.commit()
    conn.close()
    pass

def batch_insert_product(pre_list: List):
    '''
    :param pre_list: [(code,name),(code,name)]
    :return:
    '''
    conn = sqlite3.connect(YOUKUANG_DB_NAME)
    c = conn.cursor()
    # s
    sql_str = '''
    insert into t_product values (?,?)
    '''
    c.executemany(sql_str,pre_list)
    # e
    conn.commit()
    conn.close()
    pass

def one_insert_product(pre_one:List):
    '''
    :param pre_one: [code,name]
    :return:
    '''
    conn = sqlite3.connect(YOUKUANG_DB_NAME)
    c = conn.cursor()
    # s
    sql_str = '''
    insert into t_product values (?,?)
    '''
    c.execute(sql_str,pre_one)
    # e
    conn.commit()
    conn.close()
    pass

def query_products_of_exchange_name(exchange_name:str):
    conn = sqlite3.connect(YOUKUANG_DB_NAME)
    c = conn.cursor()
    # s
    exchange_name = '\'' + exchange_name + '\''
    sql_str = '''
            select code,name from t_product where exchange_name={exchange_name}
            '''.format(exchange_name=exchange_name)
    c.execute(sql_str)
    res_list = c.fetchall()
    # e
    conn.commit()
    conn.close()
    return res_list

def query_all_product_codes_of_product():
    conn = sqlite3.connect(YOUKUANG_DB_NAME)
    c = conn.cursor()
    # s
    sql_str = '''
                select code from t_product
                '''
    c.execute(sql_str)
    res_list = c.fetchall()
    # e
    conn.commit()
    conn.close()
    res_list00 = []
    for item in res_list:
        res_list00.append(item[0])
    return res_list00

create_product_table  创建表

batch_insert_product 批量插入数据

one_insert_product 单条数据插入

query_products_of_exchange_name 查询某个交易所下的品种信息

query_all_product_codes_of_product 查询所有品种代码

t_symbol_basemsg

def create_symbol_basemsg_table():
    conn = sqlite3.connect(YOUKUANG_DB_NAME)
    c = conn.cursor()
    c.execute('''
        create table if not exists t_symbol_basemsg
            (
            ticker text, 
            listDate text,
            product_code text,
            minChgPriceNum float,
            minChgPriceUnit text,
            limitUpNum float,
            limitUpUnit text,
            limitDownNum float,
            limitDownUnit text,
            contMultNum float,
            contMultUnit text,
            tradeMarginRatio float,
            deliYear integer,
            deliMonth integer,
            lastTradeDate text,
            firstDeliDate text,
            lastDeliDate text,
            tradeCommiNum float,
            tradeCommiUnit text
            )
        ''')
    conn.commit()
    conn.close()
    pass

def batch_insert_symbol_basemsg(pre_list:List):
    conn = sqlite3.connect(YOUKUANG_DB_NAME)
    c = conn.cursor()
    # s
    sql_str = '''
        insert into t_symbol_basemsg values (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)
        '''
    c.executemany(sql_str, pre_list)
    # e
    conn.commit()
    conn.close()
    pass

create_symbol_basemsg_table 创建表

batch_insert_symbol_basemsg 批量插入数据

t_main_symbol

def create_main_symbol_table():
    conn = sqlite3.connect(YOUKUANG_DB_NAME)
    c = conn.cursor()
    c.execute('''
    create table if not exists t_main_symbol 
    (product_code text, ticker text,deliYear integer,start_date text)
    ''')
    conn.commit()
    conn.close()
    pass

def one_insert_main_symbol(pre_one:List):
    conn = sqlite3.connect(YOUKUANG_DB_NAME)
    c = conn.cursor()
    # s
    sql_str = '''
            insert into t_main_symbol values (?,?,?,?)
            '''
    c.execute(sql_str, pre_one)
    # e
    conn.commit()
    conn.close()
    pass

def update_main_symbol(product_code:str,ticker:str,deliYear:int,start_date_str:str):
    conn = sqlite3.connect(YOUKUANG_DB_NAME)
    c = conn.cursor()
    # s
    ticker = '\''+ticker+'\''
    start_date_str = '\'' + start_date_str + '\''
    product_code = '\'' + product_code + '\''
    sql_str = '''
    update t_main_symbol set ticker={ticker},deliYear={deliYear},start_date={start_date} where product_code={product_code}
    '''.format(ticker=ticker,deliYear=deliYear,start_date=start_date_str,product_code=product_code)
    c.execute(sql_str)
    # e
    conn.commit()
    conn.close()
    pass

create_main_symbol_table 创建表

one_insert_main_symbol 单条数据插入

update_main_symbol 更新数据

t_online_symbol

def create_online_symbol_table():
    conn = sqlite3.connect(YOUKUANG_DB_NAME)
    c = conn.cursor()
    c.execute('''
    create table if not exists t_online_symbol 
    (product_code text, ticker text, deliYear integer, newest_date text)
    ''')
    conn.commit()
    conn.close()
    pass

def one_insert_online_symbol(pre_one:List):
    conn = sqlite3.connect(YOUKUANG_DB_NAME)
    c = conn.cursor()
    # s
    sql_str = '''
            insert into t_online_symbol values (?,?,?,?)
            '''
    c.execute(sql_str, pre_one)
    # e
    conn.commit()
    conn.close()
    pass

def batch_insert_online_symbol(pre_list:List):
    conn = sqlite3.connect(YOUKUANG_DB_NAME)
    c = conn.cursor()
    # s
    sql_str = '''
                insert into t_online_symbol values (?,?,?,?)
                '''
    c.executemany(sql_str, pre_list)
    # e
    conn.commit()
    conn.close()
    pass

create_online_symbol_table 创建表

one_insert_online_symbol 单条数据插入

batch_insert_online_symbol 批量数据插入

t_last30_daily

def create_last30_daily_table():
    conn = sqlite3.connect(YOUKUANG_DB_NAME)
    c = conn.cursor()
    c.execute('''
        create table if not exists t_last30_daily 
        (
        product_code text,
        ticker text,
        deliYear integer,
        tradeDate text,
        openPrice float,
        highestPrice float,
        lowestPrice float,
        closePrice float,
        settlePrice float,
        turnoverVol integer,
        turnoverValue integer,
        openInt integer
        )
        ''')
    conn.commit()
    conn.close()
    pass

def batch_insert_last30_daily(pre_list: List):
    conn = sqlite3.connect(YOUKUANG_DB_NAME)
    c = conn.cursor()
    # s
    sql_str = '''
    insert into t_last30_daily values (?,?,?,?,?,?,?,?,?,?,?,?)
    '''
    c.executemany(sql_str,pre_list)
    # e
    conn.commit()
    conn.close()
    pass

def query_daily_by_pro_in_last30_daily(product_code:str):
    conn = sqlite3.connect(YOUKUANG_DB_NAME)
    c = conn.cursor()
    # s
    product_code_str = '\'' + product_code + '\''
    sql_str = '''
                select product_code,ticker,deliYear,tradeDate,openPrice,highestPrice,lowestPrice,closePrice,settlePrice,turnoverVol,turnoverValue,openInt from t_last30_daily where product_code={product_code}
                '''.format(product_code=product_code_str)
    c.execute(sql_str)
    res_list = c.fetchall()
    # e
    conn.commit()
    conn.close()
    return res_list

create_last30_daily_table 创建表

batch_insert_last30_daily 批量插入数据

query_daily_by_pro_in_last30_daily 查询某品种的最近日数据

小贴士

sqlite3查看工具，SQLiteStudio，网上可以免费下载安装

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/1358430.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

LLM Agent之再谈RAG的召回多样性优化

LLM Agent之再谈RAG的召回多样性优化

1. Query多样性 2019 Query Expansion Techniques for Information Retrieval: a Survey 传统搜索Query的扩展，有基于用户搜索日志挖掘的相似Query，有基于相同召回文档关联的相似Query，也有基于SMT的Query改写方案。那和大模型时代更搭配的自…
阅读更多...
防蓝光护眼台灯哪个牌子好？2024护眼灯315合格产品

防蓝光护眼台灯哪个牌子好？2024护眼灯315合格产品

最近身边的宝妈们都来问我这个已有两个娃的老司机，刚上小学就是近视了，买什么台灯给家里孩子能保护视力，经过小学门口时，真的是戴眼镜的小朋友占多数，搜索了我国的近视数据，中国的人口有14亿人左右&#xf…
阅读更多...
个人调用OCR

个人调用OCR

一、自己训练模型 二、调用现成API 此处介绍百度智能云API，因为有免费次数。（原来一些网址在百度不是默认显示网址的，而是自己的网站名字） 首页找到OCR 每个人每月能用1K次。（有详细的API文档说明，不过跟…
阅读更多...
爱了！水浸监测这个技术，看了都说好！

爱了！水浸监测这个技术，看了都说好！

在当今社会，水浸事件可能对各类场所和设施造成严重的损害，从而威胁到财产安全和业务持续性。 水浸监控系统不仅仅是一种技术手段，更是对于防范水灾的一项战略性解决方案。水浸监控系统实时了解局势并采取迅速而有效的措施，从而最大…
阅读更多...
STM32 CubeMX产生的程序架构

STM32 CubeMX产生的程序架构

使用STM32CubeMX产生启动相关代码，配置各种外设。在后续程序开发过程中，有可能使用STM32CubeMX逐步产生使用的代码，为了将其产生的代码和我们程序隔离，一种可行的程序架构如下： 在此架构中，STM32CubeMX产生…
阅读更多...
消化性溃疡与胃肠道微生物群

消化性溃疡与胃肠道微生物群

谷禾健康 据柳叶刀统计，消化性溃疡(PUD)每年影响全球400万人，据估计普通人群终生患病率为5−10%(Lanas A et al., 2017)。尽管消化性溃疡的全球患病率在过去几十年中有所下降，但其并发症的发生率却保持不变。 消化性溃疡是指胃或十二指肠黏膜…
阅读更多...
Color Control

Color Control

设计一个优秀的用户界面是一项艰巨的任务。特别是如果你想改变UI的颜色，调整所有元素可能需要花费大量时间。Color Control可以帮助你！在检查器中以可视化的方式将你的项目颜色定义为资源。Color Control为你提供了组件，当你编辑它们时，它们会自动更新你的UI元素。 颜色控制…
阅读更多...
nodejs发送消息给钉钉机器人

nodejs发送消息给钉钉机器人

1.钉钉添加机器人 1.1 新建一个群 --> 群设置 --> 机器人 1.2 机器人管理 --> 添加机器人 1.3 机器人--> 自定义-->添加 1.4 配置信息 备注1：密钥复制出来SEC2c689174c4a8ed49c8a7309a490cd98e0e7f7bc788bb7232d53c738eb5f5d008 备注2：…
阅读更多...
OpenHarmony内存泄漏指南 - 解决问题（综合）

OpenHarmony内存泄漏指南 - 解决问题（综合）

本系列文章旨在提供定位与解决OpenHarmony应用与子系统内存泄露的常见手段与思路，将会分成几个部分来讲解。首先我们需要掌握发现内存泄漏问题的工具与方法，以及判断是否可能存在泄漏。接着需要掌握定位泄漏问题的工具，以及抓取trace、分析tr…
阅读更多...
肠道炎症与年龄和阿尔茨海默病病理学相关：一项人类队列研究

肠道炎症与年龄和阿尔茨海默病病理学相关：一项人类队列研究

谷禾健康 ​阿尔茨海默 研究表明，慢性低水平的炎症（“炎症衰老”）可能是年龄相关疾病的一个介导因素，而肠道微生物通过破坏肠道屏障可能会促进炎症。 虽然老化和阿尔茨海默病（AD）与肠道微生物群组成的改变有…
阅读更多...
Android linphone-android sdk设置语音编码问题

Android linphone-android sdk设置语音编码问题

1.遇到的问题 今天遇到linphone-android sdk需要解决语音编码问题，需要指定编码。查了下配置，里面没有发现类似的配置。 ## Start of factory rc # This file shall not contain path referencing package name, in order to be portable when app is r…
阅读更多...
逻辑回归简单案例分析--鸢尾花数据集

逻辑回归简单案例分析--鸢尾花数据集

文章目录 1. IRIS数据集介绍2. 具体步骤2.1 手动将数据转化为numpy矩阵2.1.1 从csv文件数据构建Numpy数据2.1.2 模型的搭建与训练2.1.3 分类器评估2.1.4 分类器的分类报告总结2.1.5 用交叉验证（Cross Validation）来验证分类器性能2.1.6 完整代码&#xf…
阅读更多...
web动态月球特效

web动态月球特效

文章目录 效果预览文件分布代码 效果预览 文件分布 代码 鼠标点击特效 fireworks.js class Circle {constructor({ origin, speed, color, angle, context }) {this.origin originthis.position { ...this.origin }this.color colorthis.speed speedthis.angle anglethi…
阅读更多...
OpenSSL——升级

OpenSSL——升级

OpenSSL（Open Secure Sockets Layer）是一个开源的软件库，提供了SSL和TLS协议的实现，用于加密通信。它广泛用于安全连接，例如在网站上通过HTTPS协议进行安全的数据传输. 但是从openssl申请道德证书是不安全的。对于网站…
阅读更多...
再次拓宽信创生态版图，思迈特与统信软件完成产品兼容适配认证

再次拓宽信创生态版图，思迈特与统信软件完成产品兼容适配认证

近日，思迈特软件与统信软件科技有限公司（简称“统信软件”）完成产品兼容性适配互认证，加速国产信创生态化建设进程。 本次测试由商业智能与数据分析软件（简称：Smartbi Insight V11）产品与统信服…
阅读更多...
safari缓存清理

safari缓存清理

safari缓存清理 点击顶端Safari浏览器–>点击偏好设置 点击隐私–>管理网站数据 全部移除
阅读更多...
【python】爬取豆瓣电影排行榜Top250存储到Excel文件中【附源码】

【python】爬取豆瓣电影排行榜Top250存储到Excel文件中【附源码】

一、背景 近年来，Python在数据爬取和处理方面的应用越来越广泛。本文将介绍一个基于Python的爬虫程 序，用于抓取豆瓣电影Top250的相关信息，并将其保存为Excel文件。 程序包含以下几个部分： 导入模块：程序导入了 …
阅读更多...
微同城本地小程序源码系统：顺风车+二手市场+跑腿功能+信息发布+广告功能 带完整的搭建教程

微同城本地小程序源码系统：顺风车+二手市场+跑腿功能+信息发布+广告功能 带完整的搭建教程

随着移动互联网的普及，小程序已成为各行业进行线上业务拓展的重要工具。微同城作为一款集顺风车、二手市场、跑腿功能、信息发布和广告功能于一体的本地小程序源码系统，旨在满足现代城市居民的多元化需求，提供一个方便、快捷、实用的服务平台…
阅读更多...
HackTheBox - Medium - Linux - Encoding

HackTheBox - Medium - Linux - Encoding

Encoding 前言 经过10个月左右的网安自学，我想说的第一句话无疑是：感谢TryHackMe。当然，后续的HackTheBox&学院、CRTO等等，对我的帮助都很大。 许多师傅们都在年度总结，我也看了大家都收获很多，都很…
阅读更多...
如何委婉地告诉老板，BI连接金蝶ERP，对决策更有利？

如何委婉地告诉老板，BI连接金蝶ERP，对决策更有利？

网友：新入职一家企业，发现这家企业依旧是从金蝶ERP中导出数据做分析，这样数据量一大、科目变动多就很难保证数据分析的及时性、灵活性，说真的这对决策来说并不是什么好事。但老板似乎并不觉得这有什么不对。我该如何委婉地告诉老板…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023