Advertisement
Guest User

Untitled

a guest
Oct 10th, 2016
73
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.84 KB | None | 0 0
  1. import psycopg2
  2.  
  3. # コネクション作成
  4. conn = psycopg2.connect(
  5. dbname='********',
  6. user='********',
  7. password='********',
  8. host='localhost',
  9. port='5432')
  10.  
  11. # カーソル作成
  12. cur = conn.cursor()
  13.  
  14. # sampleテーブルが既にあれば削除
  15. cur.execute('DROP TABLE IF EXISTS sample')
  16. # sampleテーブを作成
  17. cur.execute('CREATE TABLE sample (id serial PRIMARY KEY, name varchar, num integer);')
  18.  
  19. # 挿入するデータ
  20. data = [
  21. ('tanaka', 123),
  22. ('suzuki', -123),
  23. ('ogawa', None)
  24. ]
  25.  
  26. # プレースホルダーを使用
  27. for d in data:
  28. cur.execute('INSERT INTO sample (name, num) VALUES (%s, %s)', d)
  29.  
  30. # コミット
  31. conn.commit()
  32.  
  33. # SQL結果を受け取る
  34. cur.execute('SELECT * FROM sample;')
  35. print(cur.fetchall()) # [(1, 'tanaka', 123), (2, 'suzuki', -123), (3, 'ogawa', None)]
  36.  
  37. # クローズ
  38. cur.close()
  39. conn.close()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement