Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import psycopg2
- # コネクション作成
- conn = psycopg2.connect(
- dbname='********',
- user='********',
- password='********',
- host='localhost',
- port='5432')
- # カーソル作成
- cur = conn.cursor()
- # sampleテーブルが既にあれば削除
- cur.execute('DROP TABLE IF EXISTS sample')
- # sampleテーブを作成
- cur.execute('CREATE TABLE sample (id serial PRIMARY KEY, name varchar, num integer);')
- # 挿入するデータ
- data = [
- ('tanaka', 123),
- ('suzuki', -123),
- ('ogawa', None)
- ]
- # プレースホルダーを使用
- for d in data:
- cur.execute('INSERT INTO sample (name, num) VALUES (%s, %s)', d)
- # コミット
- conn.commit()
- # SQL結果を受け取る
- cur.execute('SELECT * FROM sample;')
- print(cur.fetchall()) # [(1, 'tanaka', 123), (2, 'suzuki', -123), (3, 'ogawa', None)]
- # クローズ
- cur.close()
- conn.close()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement