问题

我正在尝试将csv文件读取到Pandas，并将其写入SQLite数据库。该过程适用于csv文件中的所有列，但“ Fill qty”是正整数（int64）除外。该过程将类型从TEXT / INTEGER更改为BLOB。因此，我尝试仅将Pandas的“ Fll qty”列加载到SQLite，并且令人惊讶地发现，我可以安全地对所有小于10的整数执行此操作（我的数据集中没有9，因此基本上为1,2）。 ..，8已成功加载）。

这是我尝试过的：

我尝试了一下：将Schema中的“ Fill_Qty”类型更改为INTEGER转换为REAL，NULL或TEXT，将Pandas中的数据类型从int64更改为float或string，然后再插入SQLite表。他们都没有工作。从外观上看，“ Trade_History.csv”文件在Pandas或Excel中似乎很好。有我眼睛看不到的东西吗？！所以我真的很困惑这里发生了什么！

您将需要.csv文件来测试代码。这是代码和.csv文件：https : //github.com/Meisam-Heidari/Trading_Min_code

编码：

### Imports:
import pandas as pd
import numpy as np
import sqlite3
from sqlite3 import Error

def create_database(db_file):
    try:
        conn = sqlite3.connect(db_file)
    finally:
        conn.close()

def create_connection(db_file):
    """ create a database connection to the SQLite database
        specified by db_file
    :param db_file: database file
    :return: Connection object or None
    """
    try:
        conn = sqlite3.connect(db_file)
        return conn
    return None

def create_table(conn,table_name):  
    try:
        c = conn.cursor()
        c.execute('''CREATE TABLE {} (Fill_Qty TEXT);'''.format(table_name))
    except Error as e:
        print('Error Code:  ', e)
    finally:
        conn.commit()
        conn.close()
    return None

def add_trade(conn, table_name, trade):
    try:
        print(trade)
        sql = '''INSERT INTO {} (Fill_Qty)
              VALUES(?)'''.format(table_name)
        cur = conn.cursor()
        cur.execute(sql,trade)
    except Error as e:
        print('Error When trying to add this entry:  ',trade)
    return cur.lastrowid

def write_to_db(conn,table_name,df):
    for i in range(df.shape[0]):
        trade = (str(df.loc[i,'Fill qty']))
        add_trade(conn,table_name,trade)
        conn.commit()

def update_db(table_name='My_Trades', db_file='Trading_DB.sqlite', csv_file_path='Trade_History.csv'):
    df_executions = pd.read_csv(csv_file_path)
    create_database(db_file)
    conn = create_connection(db_file)
    table_name = 'My_Trades'
    create_table(conn, table_name)
    # writing to DB
    conn = create_connection(db_file)
    write_to_db(conn,table_name,df_executions)
    # Reading back from DB
    df_executions = pd.read_sql_query("select * from {};".format(table_name), conn)
    conn.close()
    return df_executions



### Main Body:

df_executions = update_db()

任何替代方案

我想知道是否有人有类似的经历？有什么建议/解决方案可以帮助我在SQLite中加载数据吗？我正在尝试使某些东西轻巧便携，除非没有其他选择，否则我不建议不要使用Postgres或MySQL。