mirror of https://github.com/gnosygnu/xowa
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
53 lines
2.8 KiB
53 lines
2.8 KiB
8 years ago
|
/*
|
||
|
|
XOWA: the XOWA Offline Wiki Application
|
||
|
|
Copyright (C) 2012-2017 gnosygnu@gmail.com
|
||
|
|
|
||
|
|
XOWA is licensed under the terms of the General Public License (GPL) Version 3,
|
||
|
|
or alternatively under the terms of the Apache License Version 2.0.
|
||
|
|
|
||
|
|
You may use XOWA according to either of these licenses as is most appropriate
|
||
|
|
for your project on a case-by-case basis.
|
||
|
|
|
||
|
|
The terms of each license can be found in the source code repository:
|
||
|
|
|
||
|
|
GPLv3 License: https://github.com/gnosygnu/xowa/blob/master/LICENSE-GPLv3.txt
|
||
|
|
Apache License: https://github.com/gnosygnu/xowa/blob/master/LICENSE-APACHE2.txt
|
||
|
|
*/
|
||
|
|
package gplx.dbs; import gplx.*;
|
||
|
|
import gplx.core.stores.*;
|
||
|
|
import gplx.dbs.engines.sqlite.*; import gplx.dbs.engines.mysql.*; import gplx.dbs.engines.postgres.*; import gplx.core.gfo_ndes.*;
|
||
|
|
public class Db_conn_fxt implements Rls_able {
|
||
|
|
public Db_conn Conn() {return conn;} public Db_conn_fxt Conn_(Db_conn v) {conn = v; return this;} Db_conn conn;
|
||
|
|
public void DmlAffectedAvailable_(boolean v) {dmlAffectedAvailable = v;} private boolean dmlAffectedAvailable = true;
|
||
|
|
public void ini_DeleteAll(String tbl) {conn.Exec_qry(Db_qry_.delete_tbl_(tbl));}
|
||
|
|
public void tst_ExecDml(int expd, Db_qry qry) {
|
||
|
|
int actl = conn.Exec_qry(qry);
|
||
|
|
if (dmlAffectedAvailable)
|
||
|
|
Tfds.Eq(expd, actl, "Exec_qry failed: sql={0}", qry.To_sql__exec(conn.Engine().Sql_wtr()));
|
||
|
|
}
|
||
|
|
public void tst_ExecRdrTbl(int expd, String tblName) {tst_ExecRdr(expd, Db_qry_.select_tbl_(tblName));}
|
||
|
|
public void tst_ExecRdr(int expd, Db_qry qry) {
|
||
|
|
DataRdr rdr = DataRdr_.Null;
|
||
|
|
try {
|
||
|
|
rdr = conn.Exec_qry_as_old_rdr(qry);
|
||
|
|
tbl = GfoNde_.rdr_(rdr);
|
||
|
|
}
|
||
|
|
catch (Exception e) {Err_.Noop(e); rdr.Rls();}
|
||
|
|
Tfds.Eq(expd, tbl.Subs().Count(), "Exec_qry_as_rdr failed: sql={0}", qry.To_sql__exec(conn.Engine().Sql_wtr()));
|
||
|
|
} GfoNde tbl;
|
||
|
|
public GfoNde tst_RowAry(int index, Object... expdValAry) {
|
||
|
|
GfoNde record = tbl.Subs().FetchAt_asGfoNde(index);
|
||
|
|
Object[] actlValAry = new Object[expdValAry.length];
|
||
|
|
for (int i = 0; i < actlValAry.length; i++)
|
||
|
|
actlValAry[i] = record.ReadAt(i);
|
||
|
|
Tfds.Eq_ary(actlValAry, expdValAry);
|
||
|
|
return record;
|
||
|
|
}
|
||
|
|
public void Rls() {conn.Rls_conn();}
|
||
|
|
|
||
|
|
public static Db_conn Mysql() {return Db_conn_pool.Instance.Get_or_new(Mysql_conn_info.new_("127.0.0.1", "unit_tests", "gplx_user", "gplx_password"));}
|
||
|
|
public static Db_conn Tdb(String fileName) {return Db_conn_pool.Instance.Get_or_new(Db_conn_info_.tdb_(Tfds.RscDir.GenSubDir_nest("140_dbs", "tdbs").GenSubFil(fileName)));}
|
||
|
|
public static Db_conn Postgres() {return Db_conn_pool.Instance.Get_or_new(Postgres_conn_info.new_("127.0.0.1", "unit_tests", "gplx_user", "gplx_password"));}
|
||
|
|
public static Db_conn Sqlite() {return Db_conn_pool.Instance.Get_or_new(Sqlite_conn_info.load_(Tfds.RscDir.GenSubFil_nest("140_dbs", "sqlite", "unit_tests.db")));}
|
||
|
|
public static final boolean SkipPostgres = Tfds.SkipDb || true;
|
||
|
|
}
|