×

[PR]この広告は3ヶ月以上更新がないため表示されています。
ホームページを更新後24時間以内に表示されなくなります。



Python Pylons モデルの使用(sqlite連携)



Pylonsでデータベースに接続する方法です。

QuickWiki チュートリアル
http://wiki.pylonshq.com/pages/viewpage.action?pageId=10027064
を参考にプログラムを作成しようとしたのですが・・・

アプリケーションの配布に関することも含まれており、
私にはちょっと難しかったです。

そこで、アプリケーションの配布やデータベースの初期化に
関することは抜きにして、動作させるための最低限の
設定を試してみます。


まず、データベースの設定について、
development.ini
に記載します。

[app:main]
のセクションの最後に


# invalidate the URI when specifying a SQLite db via path name
sqlalchemy.default.url = sqlite:///%(here)s/helloworld.db
#生成されたSQL文を見たい場合
#sqlalchemy.default.echo = true


と、sqliteのデータファイルの場所(接続文字列)を記載します。


次に、
/config/environment.py
にdevelopment.iniで記載した内容を取得するロジックを追加します。


#このfromを追加
from sqlalchemy import engine_from_config

#def load_environment(global_conf, app_conf):メソッドの末尾に
config['pylons.g'].sa_engine = engine_from_config(config, 'sqlalchemy.default.')


これで、configに記載したsqlalchemy.defaultの内容を
config['pylons.g'].sa_engineに反映します。



次に、
/model/__init__.py
に、
・データベース接続用のセッション
・モデルオブジェクト
の記載を行います。


from pylons import config
from sqlalchemy import Column, MetaData, Table, types
from sqlalchemy.orm import mapper
from sqlalchemy.orm import scoped_session, sessionmaker

#セッション生成
Session = scoped_session(sessionmaker(autoflush=True, autocommit=True, bind=config['pylons.g'].sa_engine))

metadata = MetaData()

#テーブル定義
pages_table = Table('pages', metadata,
  Column('id', types.Integer(), primary_key=True),
  Column('title', types.Unicode(), default=''),
  Column('content', types.Unicode(), default='')
)


#pagesテーブルを操作するオブジェクト
class Page(object):
  def __str__(self):
    return self.title

mapper(Page, pages_table)



次に、
/lib/base.py
に、/model/__init__.pyで生成したSessionがコントローラーで使用できるよう
ロジックの追加を行います。


#このfromを追加
from helloworld.model import Session

#def __call__(self, environ, start_response):の内容を修正
  try:
    return WSGIController.__call__(self, environ, start_response)
  finally:
    Session.remove()



これでやっとコントローラーでデータベースに登録されている
内容を取得できるようになりました。

コントローラ「page」を作成します。
#paster controller page


コントローラーpage.pyはこんな感じです。


import logging

from helloworld.lib.base import *

#このfromを追加
from helloworld.model import Page

log = logging.getLogger(__name__)

class PageController(BaseController):
  def index(self):
    c.titles = [page.title for page in Session.query(Page).all()]
    return render('/list.mako')


最後に
/templates/list.mako
を作成します。
※コントローラーから渡されたタイトルを表示するだけ。


% for title in c.titles:
  • ${title}

  • % endfor



    まだデータベースファイルが存在していないので、
    こんなプログラムを実行して、データベースを作成します。
    ※まだ、Python2.4を使っているので、pysqlite2を使用しています。
    2.5以降であれば、sqlite3でよいはず。


    DataBaseセットアップ用プログラム


    from pysqlite2 import dbapi2 as sqlite

    con = sqlite.connect("helloworld.db")
    cur = con.cursor()
    cur.execute("""
    create table pages(
    id int not null primary key,
    title text default '',
    content text default ''
    )
    """)
    con.commit()

    cur.execute("insert into pages(id,title,content) values (1,'title_data1','content_data1')")
    cur.execute("insert into pages(id,title,content) values (2,'title_data2','content_data2')")
    cur.execute("insert into pages(id,title,content) values (3,'title_data3','content_data3')")
    cur.execute("insert into pages(id,title,content) values (4,'title_data4','content_data4')")
    cur.execute("insert into pages(id,title,content) values (5,'title_data5','content_data5')")
    con.commit()

    cur.execute("select * from pages")
    print 'updated data'
    for r in cur:
      print r
    cur.close()
    con.close()




    サーバを起動して、ページを見てみます。


    #paster serve --reload development.ini


    http://localhost:5000/page/




    各ファイルの関係はこんな感じでしょうか?




    もどる