ORM inside web2py modules

controller.py

import myapi
orm = myapi.ORM() #database created, migrated, defined

company = orm.new_company(name='Google Inc.') #New company created or validation errors returned

client = orm.new_client(name='John', company_id=company.id) # new client created

# you could call inline
client = orm.new_client(name='John', company_id=orm.new_company('Google Inc.')) 

#this should validate and insert 

#TODO: update_or_insert and validate_or_update

myapi.py

#!/usr/bin/env python
#-*- coding: utf-8 -*-

import os
import sys
import unittest

sys.path.append(os.path.realpath('../../../'))
from gluon import *
from gluon.dal import Row

class Database(object):
    """Database Layer and table definitions"""

    def __init__(self, uri, folder):
        self.db = DAL(uri, folder=folder)
        
    def client(self):
        if not 'client' in self.db.tables:
            client = self.db.define_table('client',
                                   Field('name', required=True, requires=IS_NOT_EMPTY() ),
                                   Field('company_id', required=True, requires=IS_IN_DB(self.db, 'company.id')),
                                   )
        else:
            client = self.db.client
            
        return client


    def company(self):
        if not 'company' in self.db.tables:
            company = self.db.define_table('company',
                                    Field('name', required=True, unique=True, requires=IS_NOT_EMPTY()),
                                    )
        else:
            company = self.db.company
            
        return company
    
    def commit(self):
        self.db.commit()
        
    def rollback(self):
        self.db.rollback()


class ORM(object):
    """Creates an app ORM """

    def __init__(self):
        self.db = Database('sqlite://mydatabase.sqlite', folder=os.path.realpath('../databases'))
        commit = self.db.commit
        rollback = self.db.rollback
        self.errors = []

    def new_company(self, name):
        company = self.db.company()
        new_company = False
        try:
            new_company = company.validate_and_insert(name=name)
            self.db.commit()
        except Exception, e:
            self.errors.append(('InsertError','company',e))
            self.db.rollback()
            print self.errors

        return new_company

    def new_client(self, name, company_id):
        client = self.db.client()
        company = self.db.company()

        if isinstance(company_id, str):
            CID = company(name=company_id)
        elif isinstance(company_id, int):
            CID = company_id
        elif isinstance(company_id, Row):
            CID = company_id.id
        else:
            raise TypeError('company type not suported')

        new_client = False
        try:
            new_client = client.validate_and_insert(name=name, company_id=CID)
            self.db.commit()
        except Exception, e:
            self.errors.append(('Insert Error','client',e))
            self.db.rollback()
            print self.errors
        
        return new_client