ó

[dc@s»dZd
dl
Z
d
dlZd
dlZd
dlZd
dlZd
dlZd
dlmZ	
d
dlm
Z
d
dlm
Z

d
dlmZ
d
dlmZ
d
dlmZ
d
d	lmZ
d
d
lmZ
d
dlmZ
d
dlmZ
d
dlZd
d
lmZ
d
dlZd
dlmZ
d
dlmZ
d
dl m!Z!
d
dl"m#Z#
d
dlm$Z$
d
dlm%Z%
d
dlm&Z&
d
dl'm(Z(
d
dl'm)Z)
d
dl'm*Z*
d
dl'm+Z+
d
dl'm,Z,
d
dl-m.Z.
d
dlm/Z/
d
dl0m1Z1
d
dl0m2Z2
d
dl0m3Z3
d
dl0m4Z4
d
d l5m6Z6
d
d!l5m7Z7
d
d"l5m8Z8
d
d#l5m9Z9
d
dl:Z;d
dl<Z;d
d$l=m>Z>
d
dl;m
Z

d
d%l?m@Z@
d
d&l;mAZA
ejBd'ƒ
ZCe;jDjEZEejFeGƒ
ZHe
jIƒZJe
jIƒZKd(„ZLdd)„
ZNd*„ZOddePd+„ZQdd,„
ZRd-„ZSd.„ZTd/„ZUd0„ZVeVeSdd1„
ƒ
ƒ
ZWdd2„
ZXdd3„
ZYd4„ZZd5„Z[d6„Z\d7„ZSe[d8„ƒ
Z]e\d9„ƒ
Z^e\d:„ƒ
Z_eSd;„ƒ
Z`e\dd<„
ƒ
Zae\d=„ƒ
Zbe\d>„ƒ
Zce\ePd?„
ƒ
Zde\ePd@„
ƒ
Zee\dA„ƒ
Zfe\dB„ƒ
ZgeSdC„ƒ
Zhe[dD„ƒ
Zie	jjdEdFdGekƒe[dH„ƒ
ƒ
ZldS(Is%Implementation of SQLAlchemy backend.iÿÿÿÿN(
tapi(
t	exception(
tenginefacade(
tupdate_match(
tutils(
tlog(
texcutils(
timportutils(
t	timeutils(
t	uuidutils(
trange(
tand_(
tBoolean(
tNoSuchTableError(
tcompiles(
tInteger(
tMetaData(
tor_(
taliased(
tcontains_eager(
t
joinedload(
tnoload(
tundefer(
tTable(
tsql(
tasc(
tcast(
tdesc(
t
UpdateBase(
tfalse(
tfunc(
tnull(
ttrue(
tmodels(
t
_(
t
safe_utilssosprofiler.sqlalchemycCstj
tS(
s"The backend is this module itself.(tsystmodulest__name__(((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pytget_backendDscCs5tt
|jƒƒ
ƒ
}|
dk	r1|
|d
<n|S(Nt
connection(tdicttlisttitemstNone(t
conf_groupR(tkw((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyt_get_db_confHs




c

CsYtj
t|jƒ

tj
t|jƒ

trUtjd
„ƒ

tjd„ƒ

ndS(Nc

Sstj
t|d
ƒS(Ntdb(tprofiler_sqlalchemytadd_tracingtsa(
teng((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyt<lambda>Vsc

Sstj
t|d
ƒS(NR0(R1R2R3(
R4((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyR5Xs(tmain_context_managert	configureR/tdatabasetapi_context_managertapi_databaseR1tappend_on_engine_create(
tconf((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyR7Ns






cCs
|dkr|j
}ni}d
|kr7t|d<n>d|krPt|d<n%d|kr_nttdƒ
|ƒ
‚
tj|
|j||}t	j
j|ƒ
rÿ|rÿ|dkrç|jt
|
j|jk|
jtƒkƒƒ
}qÿ|jd|jƒ
}n|S(	s9Query helper that accounts for context's `read_deleted` field.

    :param context:     ContegoserverContext of the query.
    :param model:       Model to query. Must be a subclass of ModelBase.
    :param args:        Arguments to query. If None - model is used.
    :param read_deleted: If not None, overrides context's read_deleted field.
                        Permitted values are 'no', which does not return
                        deleted values; 'only', which only returns deleted
                        values; and 'yes', which does not filter deleted
                        values.
    :param project_only: If set and context is user-type, then restrict
                        query to match the context's project_id. If set to
                        'allow_none', restriction includes project_id = None.
    tnotdeletedtonlytyess$Unrecognized read_deleted value '%s't
allow_nonet
project_idN(R,tread_deletedtFalsetTruet
ValueErrorR"tsqlalchemyutilstmodel_querytsessiontdmapitcontexttis_user_contexttfilterRRBRt	filter_by(RKtmodeltargsRCtproject_onlytquery_kwargstquery((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyRH[s(















cCsìt|t
jd
tƒ
jtdƒ
ƒ
jtdƒ
ƒ
}|
dkrQddg}
nxY|
D]Q}|dkrpqXnd|kr”|jt|ƒ
ƒ
}qX|jt|ƒ
ƒ
}qXWx8ddgD]*}||
krº|jt|ƒ
ƒ
}qºqºW|S(	NRQssecurity_groups.rulest
info_cachetmetadatatsystem_metadatatsecurity_groupssextra.(RTRW(	RHR!tInstanceREtoptionsRR,RR(RKtcolumns_to_joinRStcolumntcol((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyt_build_instance_getŒs











c
s"tj
ˆƒ
‡f
d
†ƒ
}
|
S(sÅDecorator to use a reader.allow_async db context manager.

    The db context manager will be picked from the RequestContext.

    Wrapped function must have a RequestContext in the arguments.
    c
s<t|ƒ
}|j
jj|ƒ

ˆ||
|Ž
SWdQXdS(
N(tget_context_managertreadertallow_asynctusing(RKRPtkwargstctxt_mgr(
t
f(s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pytwrapped¨s

(t	functoolstwraps(RdRe((
Rds;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyt'pick_context_manager_reader_allow_async¡sc

Cst|ƒ
pt
S(
swGet a database context manager object.

    :param context: The request context that can contain a context manager
    (t_context_manager_from_contextR6(
RK((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyR^¯sc

Cs,|r(y|jSWq(t
k
r$


q(XndS(
N(t
db_connectiontAttributeError(
RK((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyRiµs






c
s"tj
ˆƒ
‡f
d
†ƒ
}
|
S(sE
Decorator to require *any* user or admin context.

    This does no authorization for user or project access matching, see
    :py:func:`Contegoserver.context.authorize_project_context` and
    :py:func:`Contegoserver.context.authorize_user_context`.

    The first argument to the wrapped function must be the context.

    cs!tj
j|d
ƒ

ˆ||
ŽS(Ni(RJRKtrequire_context(RPRb(
Rd(s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pytwrapperÇs
(RfRg(RdRm((
Rds;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyRl¼scCst||
d
|ƒ
S(NRZ(
t_instance_get_by_uuid(RKtuuidRZ((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pytinstance_get_by_uuidÍs
cCsCt|d
|ƒ

j
d|
ƒ
jƒ}|s?tjd|
ƒ
‚
n|S(NRZRotinstance_id(R]RNtfirstR
tInstanceNotFound(RKRoRZtresult((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyRnÔs



c
Cs,tj
ƒ}
|
jttjd
|ƒ


|
S(sfCreate a database context manager object.

    : param connection: The database connection string
    R((Rttransaction_contextR7R/tCONFR8(R(Rc((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pytcreate_context_managerßs

c
s"tj
ˆƒ
‡f
d
†ƒ
}
|
S(sZ
Decorator to select synchronous or asynchronous reader mode.
    The kwarg argument 'use_slave' defines reader mode. Asynchronous reader
    will be used if 'use_slave' is True and synchronous reader otherwise.
    If 'use_slave' is not specified default value 'False' will be used.
    Wrapped function must have a context in the arguments.
    csŽtj
ˆƒ
}tj|||
Ž
}|d
}|jdtƒ}|rXt|ƒ
j}nt|ƒ
j}|j	|ƒ

ˆ||
ŽSWdQXdS(NRKt	use_slave(
R#tget_wrapped_functiontinspecttgetcallargstgetRDR^tasync_R_Ra(RPRbtwrapped_funct
keyed_argsRKRxtreader_mode(
Rd(s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyRmñs




(RfRg(RdRm((
Rds;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pytselect_db_reader_modeésc
s"tj
ˆƒ
‡f
d
†ƒ
}
|
S(s·Decorator to use a writer db context manager.
    The db context manager will be picked from the RequestContext.
    Wrapped function must have a RequestContext in the arguments.
    c
s9t|ƒ
}|j
j|ƒ

ˆ||
|Ž
SWdQXdS(
N(R^twriterRa(RKRPRbRc(
Rd(s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyRe
s

(RfRg(RdRe((
Rds;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pytpick_context_manager_writer
sc
s"tj
ˆƒ
‡f
d
†ƒ
}
|
S(s·Decorator to use a reader db context manager.
    The db context manager will be picked from the RequestContext.
    Wrapped function must have a RequestContext in the arguments.
    c
s9t|ƒ
}|j
j|ƒ

ˆ||
|Ž
SWdQXdS(
N(R^R_Ra(RKRPRbRc(
Rd(s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyRe
s

(RfRg(RdRe((
Rds;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pytpick_context_manager_reader
sc
s"tj
ˆƒ
‡f
d
†ƒ
}
|
S(sÃDecorator to use a reader.allow_async db context manager.
    The db context manager will be picked from the RequestContext.
    Wrapped function must have a RequestContext in the arguments.
    c
s<t|ƒ
}|j
jj|ƒ

ˆ||
|Ž
SWdQXdS(
N(R^R_R`Ra(RKRPRbRc(
Rd(s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyRe"
s

(RfRg(RdRe((
Rds;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyRh
scCs—t||
ƒ}t
|tjƒjd
|
ƒ
jdtƒ

|jdkr“t
|tjƒj	t
tjj|
ktjj|dkƒƒ
jdtƒ

ndS(Ntidtsynchronize_sessionstvault-contegothost(
tservice_getRHR!tServiceRNtsoft_deleteRDtbinarytComputeNodeRMRt
service_idR‡(RKRtservice((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pytservice_destroy-
s





cCsIt|t
jƒjd
|
ƒ
}|jƒ}|sEtjd|
ƒ
‚
n|S(NR…R(RHR!R‰RNRrR
tServiceNotFound(RKRRSRt((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyRˆ<
s


cCsIt|t
jƒjd
|
ƒ
}|jƒ}|sEtjd|
ƒ
‚
n|S(NRoR(RHR!R‰RNRrR
R(RKtservice_uuidRSRt((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pytservice_get_by_uuidG
s


cCsˆ|jj
tjjtjtjjƒ
ƒjtjjj	|
ƒ
ƒ
jtjj
d
kƒ
jtjjtƒkƒ
j
tjjƒ
}t|ƒ
S(Ni(RIRSR!R‰R‹RtmintversionRMtin_R>tforced_downRtgroup_byR)(RKtbinariestmin_versions((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pytservice_get_minimum_versionR
s	
	





cCs=t|t
jƒ}|
dk	r3|jd
|
ƒ
}n|jƒS(Ntdisabled(RHR!R‰R,RNtall(RKR›RS((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pytservice_get_all^
s
cCs4t|t
jd
dƒ
jdtƒ
jd|
ƒ
jƒS(NRCR=R›ttopic(RHR!R‰RNRDRœ(RKRž((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pytservice_get_all_by_topich
s

cCs@t|t
jd
dƒ
jdtƒ
jd|
ƒ
jd|ƒ
jƒS(NRCR=R›R‡Rž(RHR!R‰RNRDRr(RKR‡Rž((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pytservice_get_by_host_and_topicp
s


cCsCt|t
jƒjd
|
ƒ
}|s9|jdtƒ
}n|jƒS(NR‹R›(RHR!R‰RNRDRœ(RKR‹tinclude_disabledRS((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pytservice_get_all_by_binaryy
s


cCsŽt|t
jd
dƒ
jddƒ
}|s?|jdtƒ
}n|jt
jt
jjt
jjkƒjt
jj	|
kƒ
j
dƒ
}|jƒS(NRCR=R‹stvault-contegoR›R‡(RHR!R‰RNRDtjoinRŒR‡RMthypervisor_typetdistinctRœ(RKthv_typeR¡RS((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyt#service_get_all_computes_by_hv_type
s
	





	
cCs[t|t
jd
dƒ
jd|
ƒ
jd|ƒ
jƒ}|sWtjd|
d|ƒ‚
n|S(NRCR=R‡R‹(RHR!R‰RNRrR
tHostBinaryNotFound(RKR‡R‹Rt((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pytservice_get_by_host_and_binary
s


cCs(t|t
jd
dƒ
jd|
ƒ
jƒS(NRCR=R‡(RHR!R‰RNRœ(RKR‡((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pytservice_get_all_by_hostœ
s
cCsUt|t
jd
dƒ
jd|
ƒ
jddƒ
jƒ}|sQtjd|
ƒ
‚
n|S(NRCR=R‡R‹stvault-contego(RHR!R‰RNRrR
tComputeHostNotFound(RKR‡Rt((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pytservice_get_by_compute_host£
s


cCs°tj
ƒ}|j|
ƒ

y|j|jƒ

Wn|tjk
r«
}
d
|jkr~tj	d|
j
dƒ
d
|
j
d
ƒ
ƒ‚
ntjd|
j
dƒ
d|
j
dƒ
ƒ‚
n
X|S(NR‹R‡Rž(R!R‰tupdatetsaveRItdb_exctDBDuplicateEntrytcolumnsR
tServiceBinaryExistsR|tServiceTopicExists(RKtvaluestservice_reft
e((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pytservice_create°
s










tmax_retriesitretry_on_deadlockcCsTt||
ƒ}d
|krC|d
|j
krCtjƒ|_qCn|j|ƒ

|S(Ntreport_count(RˆRºRtutcnowtlast_seen_upR­(RKRR´Rµ((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pytservice_update¿
s




(mt__doc__tcollectionstcopytdatetimeRfRzR$toslo_dbRtoslo_db_apiR
R¯toslo_db.sqlalchemyRRRRGtoslo_logRtloggingt
oslo_utilsRRRR	tsixt	six.movesR
t
sqlalchemyR3RRtsqlalchemy.excR
tsqlalchemy.ext.compilerRRRRtsqlalchemy.ormRRRRRtsqlalchemy.schemaRRtsqlalchemy.sql.expressionRRRRtsqlalchemy.sqlRRRR t
dmapi.confRJt
dmapi.contexttdmapi.db.sqlalchemyR!t
dmapi.i18nR"R#t
try_importR1R<Rvt	getLoggerR&tLOGRuR6R9R'R,R/R7RDRHR]RhR^RiRlRpRnRwRRƒR„RRˆR’RšRRŸR R¢R§R©RªR¬R·t
wrap_db_retryRER½(((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyt<module>s´












































		

.