from sqlalchemy import *
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.pool import StaticPool
URL = "ibm_db_sa+pyodbc400://{user}:{password}@{host}:{port}/{database}"
engine = create_engine(URL, poolclass=StaticPool, echo=True)
meta = MetaData(bind=engine, schema="test")
db_session = sessionmaker(bind=engine)
model = declarative_base(metadata=meta)
class Client(model):
__tablename__ = 'client'
id = Column(Integer, autoincrement=True, nullable=False, primary_key=True)
name = Column(String(128), nullable=True)
def __init__(self, name):
self.name = name
def add_client(client_details):
session = db_session()
client = Client(**client_details)
session.add(client)
session.flush()
return True
def add_client1(client_name):
session = db_session()
session.execute("INSERT INTO edcservice.client(name) values('" + client_name + "')")
return True
client_data = {"name": "test"}
add_client(client_data)
client_name = "test"
add_client1(client_name)