Python의 SQLAlchemy에 대한 간략한 소개
- 不言앞으로
- 2018-10-23 16:44:242826검색
SQLAlchemy는 Python 프로그래밍 언어를 사용하는 오픈 소스 소프트웨어입니다. SQL 툴킷과 ORM(객체 관계형 매핑) 도구를 제공하는 SQLAlchemy는 MIT 라이선스에 따라 출시됩니다. 효율적인 고성능 데이터베이스 액세스를 위해 설계된 간단한 Python 언어를 사용하여 완전한 엔터프라이즈급 지속성 모델을 구현합니다. SQLAlchemy는 데이터베이스 크기와 성능에 큰 관심을 기울입니다.
이 섹션에서는 일련의 예제를 통해 SQLAlchemy의 사용을 분석합니다.
SQLAlchemy를 사용하려면 테이블 정의, 데이터베이스 연결 정의, 추가, 삭제, 수정, 쿼리와 같은 논리 작업을 수행하는 코드가 세 부분 이상 필요합니다.
정의 테이블 인스턴스:
from sqlalchemy.ext.declarative import declarative_base from sqlalchemy import Column,Integer,String Base=declarative_base() class Accout(Base): __tablename__=u'accout' id=Column(Integer,primary_key=True) user_namr=Column(String(50),nullable=False) password=Column(String(200),nullable=False) title=Column(String(50)) salary=Column(Integer) def is_active(self): #假设所有 return True def get_id(self): #返回账号ID，用方法返回属性值提高了表的封装性。 return self.id def is_authenticated(self): #假设已经通过验证 return True def is_anonymous(self): #具有登陆名和密码的账号不是匿名用户 return False
정의 테이블을 구문 분석하는 코드는 다음과 같습니다.
SQLAlchemy 테이블은 sqlalchemy.ext.declarative_base 이전에 도입되어야 하며 해당 테이블의 인스턴스 기반을 정의해야 합니다. 모든 테이블은 Base에서 상속되어야 합니다. 이 예에서는 계정 테이블 클래스 Account가 정의됩니다.
데이터베이스에 있는 테이블의 실제 이름 계정은 __tablename__ 속성을 통해 정의됩니다.
테이블에서 열을 정의하는 데 사용되는 Column, Integer 및 String 유형을 sqlalchemy 패키지에 도입하세요. 이 예에서는 Account 테이블에 정수 ID 및 급여라는 5개 열과 user_name, 비밀번호 및 제목 문자열 유형을 정의합니다.
열을 정의할 때 Column에 매개변수를 전달하여 제약 조건을 정의할 수 있습니다. 이 예에서는 기본 키 매개변수를 사용하여 id 열을 기본 키로 정의하고, nullable 매개변수를 사용하여 user__name 및 비밀번호를 null이 아닌 것으로 정의합니다.
표의 다른 기능을 맞춤설정할 수도 있습니다. 이 예에서는 사용자 인증에 일반적으로 사용되는 여러 함수(is__activite(), get__id(), is__authenticate() 및 is_anonymous()))를 정의합니다.
데이터베이스 연결을 정의하는 샘플 코드는 다음과 같습니다.
from sqlalchemy import create_engine
from sqlalchemy.orm import scoped_session,sessionmaker
from contextlib import contextmanager
db_connect_string='mysql://v_user:v_pase@localhost:3306/test_database?charset=utf8'
ssl_args={
'ssl':{
'cert':'/home/ssl/client-cert.pem',
'key':'/home/shouse/ssl/client-key.pem',
'ca':'/home/shouse/ssl/ca-cert.pem'
}
}
engine=create_engine(db_connect_string,connect_args=ssl_args)
SessionType=scoped_session(sessionmaker(bind=engine,expire_on_commit=False))
def GetSession():
return SessionType()
@contextmanager
def session_scope():
session=GetSession()
try:
yield session
session.commit()
except:
session.rollback()
raise
finally:
session.close()
이 연결의 데이터 부분을 구문 분석하는 코드는 다음과 같습니다.
데이터베이스 및 세션 엔진 소개: sqlalchemy.create_ 엔진, sqlalchemy.orm.scoped_session, sqlalchemy.orm.sessionmaker.
데이터베이스에 연결하는 데 필요한 데이터베이스 문자열을 정의합니다. 이 예에서는 MySQL 데이터베이스가 연결되어 있습니다. 문자열 형식은 [databse_type]://[user_name]:[password]@[domain]:[port]/[database]?[parameters]입니다. 이 예에서는 필요한 연결 정보 외에도 데이터베이스의 문자열을 디코딩하기 위한 UTF-8 인코딩 방법을 지정하는 charset 매개변수도 전달됩니다.
create_engine을 사용하여 데이터베이스 엔진을 생성하세요. 데이터베이스에 SSL 링크가 활성화되어 있으면 여기에 SSL 클라이언트 인증서의 파일 경로를 전달해야 합니다.
scoped_session(sessionmaker(bind=engine))을 사용하여 세션 유형 SessionType을 생성하고 GetSession() 함수를 정의하여 SessionType의 인스턴스를 생성합니다.
이 시점에서 GetSession() 함수를 사용하여 데이터베이스 세션을 생성하고 데이터베이스 작업을 수행할 수 있습니다. 그러나 후속 데이터베이스 연산 코드가 자동으로 트랜잭션 처리를 수행할 수 있도록 하기 위해 이 예제에서는 컨텍스트 함수 session_scope()를 정의합니다. Python에서 컨텍스트 함수를 정의하는 방법은 contextlib 패키지에 contextmanager 데코레이터를 추가하는 것입니다. 컨텍스트 함수에서는 다음 논리가 실행됩니다. 함수 시작 시 데이터베이스 세션이 설정되고 이때 데이터베이스 트랜잭션이 자동으로 설정됩니다. 예외가 발생하면 트랜잭션이 롤백되고 종료 시 연결이 닫힙니다. 연결이 닫히면 트랜잭션 커밋 작업이 자동으로 수행됩니다.
데이터베이스 작업 코드:
from sqlalchemy import or_,orm
def InsertAccount(user,passwd,title,salary): #新增操作
with session_scope() as session:
account=orm.Account(user_name=user,passwd=passwd,title=title,salary=salary)
session.add(account)
def GetAccount(id=None,user_name=None): #查询操作
with session_scope() as session:
return session.query(orm.Account).filter(
or_(orm.Account.id==id,orm.Account.user_name=user_name)
).first()
def DeleteAccount(user_name): #删除操作
with session_scope() as session:
account=GetAccount(user_name=user_name)
if account:
session.delete(account)
def UpdateAccount(id,user_name,password,title,salary): #更新操作
with session_scope() as session:
account=session.query(orm.Account).filter(orm.Account.id==id).first()
if not account:return
account.user_name=user_name
account.password=password
account.salary=salary
account.title=title
InsertAccount("Mark","123","Manager",3000) #调用新增操作
InsertAccount("帅哥","456","Boss",2000) #调用新增操作
GetAccount(2) #调用查询操作
DeleteAccount("Mark")
UpdateAccount(1,"admin","none","System admin",2500)
이 예에서는 데이터베이스에서 가장 일반적으로 사용되는 4가지 레코드 기반 작업인 추가, 검색, 삭제 및 업데이트를 보여줍니다. 이 부분의 코드를 분석하면 다음과 같습니다.
import 문을 사용하여 데이터 테이블(Account)이 있는 패키지 orm을 소개합니다. 다중 조건 쿼리를 도입할 때는 or_를 사용하세요.
각 함수에서 context 함수 session_scope()는 with 문을 통해 활성화되며, 이를 통해 세션 개체를 얻고 새로운 작업이 자동으로 시작됩니다.
InsertAccount에서 새 테이블 Account 인스턴스를 생성하고 session.add를 통해 데이터베이스에 추가합니다. 컨텍스트 함수가 종료되면 트랜잭션이 자동으로 커밋되므로 새 추가 사항을 적용하기 위해 명시적으로 session.commit()을 호출할 필요가 없습니다.
은 GetAccount의 쿼리문을 통해 쿼리됩니다. 쿼리 조건은 필터로 설정됩니다. or_ 또는 and_로 여러 쿼리 조건을 연결할 수 있습니다.
삭제 계정에서 GetAccount를 통해 객체를 쿼리합니다. 발견되면 session.delete()를 직접 호출하여 객체를 삭제합니다.
InsertAccount()에서 쿼리를 통해 id를 기준으로 레코드를 쿼리합니다. 쿼리가 발견되면 개체의 속성을 설정하여 레코드를 수정합니다.
쿼리 문의 결과는 개체 모음입니다. 쿼리 문 뒤의 first() 함수는 컬렉션의 첫 번째 개체를 추출하는 데 사용됩니다. first() 함수가 all() 함수로 대체되면 쿼리는 컬렉션을 반환합니다.
주류 데이터베이스에 대한 연결 방법
SQLAlchemy와 같은 Orm 데이터베이스 운영 방법은 비즈니스 개발자를 서로 다른 데이터베이스 간의 차이점으로부터 보호할 수 있으므로 데이터베이스 마이그레이션이 필요한 경우(예: MySQL을 SQLite로 마이그레이션) 데이터베이스만 연결 문자열을 변경해야 합니다.
다음 표에는 SQLAlchemy가 주류 데이터베이스에 연결할 때 데이터베이스 문자열의 쓰기 방법이 나열되어 있습니다.
| 数据库 数据库 字 符串 | |
| microsoft sqlserver | |
| MySQL | |
| Oracle |
위 내용은 Python의 SQLAlchemy에 대한 간략한 소개의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!