twitools/csvdb.py

#!/usr/bin/env python3

import tools

import sqlite3, csv

try:
 infile = open('tweets.csv')
except IOError:
 raise IOError("Please make sure that the tweets.csv from the Twitter download is located in this directory.")

input = list(csv.reader(infile))

conn = sqlite3.connect('Database.db')
cur = conn.cursor()

try:
 cur.execute("CREATE TABLE tweets(`tweet_id` INTEGER NOT NULL, `in_reply_to_status_id` TEXT, `in_reply_to_user_id` TEXT, `timestamp` TEXT, `source` TEXT, `text` TEXT, `retweeted_status_id` TEXT, `retweeted_status_user_id` TEXT, `retweeted_status_timestamp` TEXT, `expanded_urls` TEXT, PRIMARY KEY(tweet_id));")
except sqlite3.OperationalError:
 raise IOError("Database.db already exists. Please delete it before trying to create a new one.")

for row in input[1:]:
 cur.execute("INSERT INTO tweets VALUES(" + row[0].replace("'","''") + ",'" + row[1].replace("'","''")  + "','" + row[2].replace("'","''")  + "','" + row[3].replace("'","''")  + "','" + row[4].replace("'","''")  + "','" + row[5].replace("'","''")  + "','" + row[6].replace("'","''")  + "','" + row[7].replace("'","''")  + "','" + row[8].replace("'","''")  + "','" + row[9].replace("'","''")  + "');")

conn.commit()