本文整理汇总了Java中javax.xml.xquery.XQConnection类的典型用法代码示例。如果您正苦于以下问题:Java XQConnection类的具体用法?Java XQConnection怎么用?Java XQConnection使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
XQConnection类属于javax.xml.xquery包,在下文中一共展示了XQConnection类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: testGetBoolean
import javax.xml.xquery.XQConnection; //导入依赖的package包/类
@Test
public void testGetBoolean() throws XQException {
SaxonXQDataSource xqds = new SaxonXQDataSource();
XQConnection xqc = xqds.getConnection();
XQExpression xqe = xqc.createExpression();
xqe.bindObject(new QName("v"), Boolean.valueOf(true), null);
XQSequence xqs = xqe.executeQuery("declare variable $v external; $v instance of xs:boolean");
xqs.next();
assertTrue("expected true but got false", xqs.getBoolean());
xqe.bindObject(new QName("v"), new Byte((byte) 1), null);
xqs = xqe.executeQuery("declare variable $v external; $v instance of xs:byte");
xqs.next();
assertTrue("expected true (byte) but got false", xqs.getBoolean());
xqs.close();
}
开发者ID:dsukhoroslov,项目名称:bagri,代码行数:19,代码来源:SaxonParserTest.java
示例2: testBinding
import javax.xml.xquery.XQConnection; //导入依赖的package包/类
@Test
public void testBinding() throws XQException {
SaxonXQDataSource xqds = new SaxonXQDataSource();
XQConnection xqc = xqds.getConnection();
XQPreparedExpression xqpe = xqc.prepareExpression("declare variable $v external; $v");
xqpe.bindString(new QName("v"), "Hello world!", xqc.createAtomicType(XQItemType.XQBASETYPE_STRING));
XQSequence xqs = xqpe.executeQuery();
assertTrue(xqs.next());
assertEquals("Hello world!", xqs.getAtomicValue());
xqpe.close();
xqpe = xqc.prepareExpression("declare variable $v external; $v");
xqpe.bindString(new QName("v"), "Hello", xqc.createAtomicType(XQItemType.XQBASETYPE_NCNAME));
xqs = xqpe.executeQuery();
xqs.next();
assertEquals("A-XQDC-1.7: Successful bindXXX.", XQItemType.XQITEMKIND_ATOMIC, xqs.getItemType().getItemKind());
assertEquals("A-XQDC-1.7: Successful bindXXX.", XQItemType.XQBASETYPE_NCNAME, xqs.getItemType().getBaseType());
assertEquals("A-XQDC-1.7: Successful bindXXX.", "Hello", xqs.getObject());
xqpe.close();
}
开发者ID:dsukhoroslov,项目名称:bagri,代码行数:21,代码来源:SaxonParserTest.java
示例3: initConnection
import javax.xml.xquery.XQConnection; //导入依赖的package包/类
private XQConnection initConnection(String username) throws XQException {
BagriXQConnection connect = createConnection(username);
Object xqp = makeInstance(XQ_PROCESSOR);
if (xqp != null) {
if (xqp instanceof XQProcessor) {
connect.setProcessor((XQProcessor) xqp);
((XQProcessor) xqp).setXQDataFactory(connect);
Object xdm = initRepository(connect);
if (xdm != null) {
if (xdm instanceof SchemaRepository) {
((XQProcessor) xqp).setRepository((SchemaRepository) xdm);
} else {
throw new XQException("Specified Repository class does not implement XDMRepository interface: " +
properties.getProperty(XDM_REPOSITORY));
}
}
} else {
throw new XQException("Specified XQ Processor class does not implement XQProcessor interface: " +
properties.getProperty(XQ_PROCESSOR));
}
}
return connect;
}
开发者ID:dsukhoroslov,项目名称:bagri,代码行数:26,代码来源:BagriXQDataSource.java
示例4: getConnection
import javax.xml.xquery.XQConnection; //导入依赖的package包/类
@Override
public XQConnection getConnection() throws XQException {
// get pooled connection from pool
// if no spare connections - grow pool..?
PooledXQConnection xqConn;
synchronized (pool) {
if (pool.size() > 0) {
xqConn = pool.pop();
} else {
xqConn = poolSource.getPooledConnection();
}
}
xqConn.addConnectionEventListener(this);
XQConnection conn = xqConn.getConnection();
logger.debug("getConnection; pool size: {}; returning: {}", pool.size(), conn);
return conn;
}
开发者ID:dsukhoroslov,项目名称:bagri,代码行数:18,代码来源:BagriConnectionPool.java
示例5: testStoreSecurity
import javax.xml.xquery.XQConnection; //导入依赖的package包/类
@Test
public void testStoreSecurity() throws XQException {
String dName = "../etc/samples/tpox/";
String xml;
try {
xml = readTextFile(dName + "security1500.xml");
} catch (IOException ex) {
throw new XQException(ex.getMessage());
}
String query = "declare namespace bgdb=\"http://bagridb.com/bdb\";\n" +
"declare variable $url external;\n" +
"declare variable $xml external;\n" +
"let $id := bgdb:store-document($url, $xml)\n" +
"return $id\n";
XQConnection xqc = xqds.getConnection();
XQPreparedExpression xqpe = xqc.prepareExpression(query);
xqpe.bindString(new QName("url"), "security1500.xml", xqc.createAtomicType(XQItemType.XQBASETYPE_ANYURI));
xqpe.bindString(new QName("xml"), xml, xqc.createAtomicType(XQItemType.XQBASETYPE_STRING));
XQSequence xqs = xqpe.executeQuery();
assertTrue(xqs.next());
xqs.close();
xqpe.close();
}
开发者ID:dsukhoroslov,项目名称:bagri,代码行数:26,代码来源:BagriXQDataSourceTest.java
示例6: runQuery
import javax.xml.xquery.XQConnection; //导入依赖的package包/类
private static String runQuery(String query) throws XQException {
System.out.println("runQuery: \n\t" + query);
XQDataSource xqs = new ExistXQDataSource();
String returnString = "";
xqs.setProperty("serverName", "localhost");
xqs.setProperty("port", "8080");
XQConnection conn = xqs.getConnection();
XQPreparedExpression xqpe = conn.prepareExpression(query);
XQResultSequence rs = xqpe.executeQuery();
while (rs.next()) {
returnString += rs.getItemAsString(null).replace("xmlns=\"\"", "")
+ "\n";
}
System.out.println("Query result: \n\t" + returnString);
return returnString;
}
开发者ID:XMLVersioningFramework,项目名称:XMLVersioningFramework,代码行数:24,代码来源:XChroniclerHandler.java
示例7: setUp
import javax.xml.xquery.XQConnection; //导入依赖的package包/类
@Before
public void setUp() throws Exception {
config = mock(XQueryRunConfig.class);
binderFactory = mock(TypeBinderFactory.class);
connection = mock(XQConnection.class);
expression = mock(XQPreparedExpression.class);
binder = new ContextItemBinder(binderFactory, config) {
@Override
protected String readFile(String fileName) throws IOException {
fileRead = true;
return FILE_CONTENTS;
}
};
typeBinder = mock(TypeBinder.class);
given(binderFactory.getBinder(CONTEXT_ITEM_TYPE)).willReturn(typeBinder);
}
开发者ID:ligasgr,项目名称:intellij-xquery,代码行数:17,代码来源:ContextItemBinderTest.java
示例8: testXQueryExpression
import javax.xml.xquery.XQConnection; //导入依赖的package包/类
/**
*
* @throws XQException
* @throws XQException
* @throws JAXBException
* @throws IOException
*/
@Test
public void testXQueryExpression() throws XQException
{
String sourceFile="synderTest.xml";
String xqFile="synderQuery1.xq";
Configuration saxonConfig = new Configuration();
SaxonXQDataSource dataSource = new SaxonXQDataSource(saxonConfig);
XQConnection conn = dataSource.getConnection();
String xsString="for $Template in doc(\"synderTest.xml\")/TemplateContainer/Template/Tags "+
" return $Template" ;
XQPreparedExpression exp = conn.prepareExpression(xsString);
URI sourcUri=new File(sourceFile).toURI();
// exp.bindString(new QName("docName"), sourcUri.getPath(), conn
// .createAtomicType(XQItemType.XQBASETYPE_STRING));
XQResultSequence result = exp.executeQuery();
String rawResult = result.getSequenceAsString(new Properties());
System.out.println("TransformTest.testXQueryExpression()..:"+rawResult);
// System.out.println(tester.transfer(sourceFile, xqFile));
}
开发者ID:NCIP,项目名称:caadapter,代码行数:31,代码来源:TransformTest.java
示例9: executeQuery
import javax.xml.xquery.XQConnection; //导入依赖的package包/类
public String executeQuery(String query) throws XQException{
log.debug("语句执行begin:"+query);
XQConnection connection= this.getXqConnection();
String result = connection.createExpression().executeQuery(query).getSequenceAsString(null);
log.debug("语句执行end:"+result);
return result;
}
开发者ID:javaliquan,项目名称:XWorld,代码行数:8,代码来源:XQSession.java
示例10: executeQuerySequence
import javax.xml.xquery.XQConnection; //导入依赖的package包/类
public XQSequence executeQuerySequence(String query) throws XQException{
log.debug("sequence语句执行begin:"+query);
XQConnection connection= this.getXqConnection();
XQSequence sequence = connection.createExpression().executeQuery(query);
log.debug("sequence语句执行end");
return sequence;
}
开发者ID:javaliquan,项目名称:XWorld,代码行数:8,代码来源:XQSession.java
示例11: openXQSession
import javax.xml.xquery.XQConnection; //导入依赖的package包/类
public XQSession openXQSession() throws XQException {
BaseXXQDataSource xqds = new BaseXXQDataSource();
xqds.setProperty("serverName", ProperConfigUtil.getConfigByKey("SERVERIP"));
xqds.setProperty("port",ProperConfigUtil.getConfigByKey("SERVERPORT"));
XQConnection conn = xqds.getConnection(ProperConfigUtil.getConfigByKey("USER"),ProperConfigUtil.getConfigByKey("PASSWORD"));
XQSession session = new XQSession(conn);
return session;
}
开发者ID:javaliquan,项目名称:XWorld,代码行数:9,代码来源:XQSessionFactory.java
示例12: executeQuerySequence
import javax.xml.xquery.XQConnection; //导入依赖的package包/类
public XQSequence executeQuerySequence(String query, Map bind_map)
throws XQException {
XQSequence sequence = null;
XQConnection connection = this.getXqConnection();
if (bind_map != null && !bind_map.isEmpty()) {
if(log.isDebugEnabled()){
log.debug("查询参数:"+bind_map);
}
// bind
if (bind_map != null && !bind_map.isEmpty()) {
XQPreparedExpression expression = connection
.prepareExpression(query);
Set<Map.Entry> set = bind_map.entrySet();
for (Iterator<Map.Entry> it = set.iterator(); it.hasNext();) {
Map.Entry entry = (Map.Entry) it.next();
String value = (String) entry.getValue();
if(value!=null){
expression.bindAtomicValue(new QName((String) entry.getKey()),
value, null);
}
}
sequence = expression.executeQuery();
} else {
sequence = connection.createExpression().executeQuery(query);
}
} else {
sequence = connection.createExpression().executeQuery(query);
}
return sequence;
}
开发者ID:javaliquan,项目名称:XWorld,代码行数:31,代码来源:XQSession.java
示例13: setupXQConnection
import javax.xml.xquery.XQConnection; //导入依赖的package包/类
private void setupXQConnection(ApplicationContext ctx) throws XQException {
XQDataSource xqds = ctx.getBean("xqDataSource", XQDataSource.class);
String username = srvUser.getCurrentUser();
String password = srvUser.getUserPassword(username);
if (password == null) {
throw new XQException("no credentials found for user " + username);
}
XQConnection xqConn = xqds.getConnection(username, password);
QueryManagement qMgr = ctx.getBean("queryManager", QueryManagement.class);
qMgr.setXQConnection(xqConn);
}
开发者ID:dsukhoroslov,项目名称:bagri,代码行数:13,代码来源:SchemaManagement.java
示例14: main
import javax.xml.xquery.XQConnection; //导入依赖的package包/类
public static void main(String[] args) throws XQException {
//System.setProperty("bdb.schema.members", "localhost:10600");
System.setProperty("logback.configurationFile", "hz-client-logging.xml");
System.setProperty("bdb.log.level", "trace");
//
context = new ClassPathXmlApplicationContext("spring/xqj-client-context.xml");
XQConnection xqc = context.getBean("xqConnection", XQConnection.class);
ClientApp client = new ClientApp(xqc);
//HazelcastInstance hz = context.getBean("hzInstance", HazelcastInstance.class);
boolean found = false;
try {
//client.storeSecCommand();
long id = client.storeSecQuery();
//long id = client.storeXmlDocument("axis.xml");
//System.out.println("document stored; id: " + id);
//found = client.runPriceQuery("IBM");
//found &= client.runPriceQuery("IBM");
found = client.runSecQuery("IBM");
//found &= client.runSecQuery("VFINX");
//found &= client.runPriceQuery("PTTAX");
//found = client.searchSecQuery();
//found = client.searchSecQueryParams();
//client.searchSecQueryParams();
//found = client.runAxisQuery();
//client.removeSecCommand(id);
} catch (XQException e) {
e.printStackTrace();
}
if (!found) {
throw new XQException("result is empty");
}
//context.close();
}
开发者ID:dsukhoroslov,项目名称:bagri,代码行数:38,代码来源:ClientApp.java
示例15: main
import javax.xml.xquery.XQConnection; //导入依赖的package包/类
public static void main(String[] args) throws Exception {
ApplicationContext context = new ClassPathXmlApplicationContext("spring/xqj-client-context.xml");
XQConnection xqc = context.getBean("xqConnection", XQConnection.class);
XQJClientSpringApp client = new XQJClientSpringApp(xqc);
tester.testClient(client);
}
开发者ID:dsukhoroslov,项目名称:bagri,代码行数:9,代码来源:XQJClientSpringApp.java
示例16: main
import javax.xml.xquery.XQConnection; //导入依赖的package包/类
public static void main(String[] args) throws XQException {
System.setProperty(pn_config_properties_file, "embedded.properties");
context = new ClassPathXmlApplicationContext("spring/xqj-embedded-context.xml");
XQConnection xqc = context.getBean("xqFactory", XQConnection.class);
EmbeddedApp client = new EmbeddedApp(xqc);
//HazelcastInstance hz = context.getBean("hzInstance", HazelcastInstance.class);
boolean found = false;
try {
//client.storeSecCommand();
long id = client.storeSecQuery();
//long id = client.storeXmlDocument("axis.xml");
//System.out.println("document stored; id: " + id);
//found = client.runPriceQuery();
//client.runPriceQuery();
//found = client.runSecQuery();
//client.runSecQuery();
//found = client.searchSecQuery();
found = client.searchSecQueryParams();
//client.searchSecQueryParams();
//found = client.runAxisQuery();
client.removeSecCommand(id);
} catch (XQException ex) {
ex.printStackTrace();
}
if (!found) {
throw new XQException("result is empty");
}
//context.close();
}
开发者ID:dsukhoroslov,项目名称:bagri,代码行数:35,代码来源:EmbeddedApp.java
示例17: initialValue
import javax.xml.xquery.XQConnection; //导入依赖的package包/类
@Override
protected XQConnection initialValue() {
try {
XQConnection xqc = xqds.getConnection();
setProperty(((BagriXQDataFactory) xqc).getProcessor().getProperties(), pn_client_fetchSize, null);
setProperty(((BagriXQDataFactory) xqc).getProcessor().getProperties(), pn_client_submitTo, null);
setProperty(((BagriXQDataFactory) xqc).getProcessor().getProperties(), pn_client_ownerParam, null);
logger.info("initialValue.exit; XQC: {}", xqc);
return xqc;
} catch (XQException ex) {
logger.error("", ex);
return null;
}
}
开发者ID:dsukhoroslov,项目名称:bagri,代码行数:15,代码来源:BagriXQJPlugin.java
示例18: close
import javax.xml.xquery.XQConnection; //导入依赖的package包/类
@Override
public void close() throws SQLException {
XQConnection conn = getConnection();
if (!conn.isClosed()) {
logger.info("close; XQC: {}", conn);
try {
conn.close();
} catch (XQException ex) {
logger.error("close.error; " + ex, ex);
throw new SQLException(ex);
}
} else {
logger.debug("close; XQC is already closed: {}", conn);
}
}
开发者ID:dsukhoroslov,项目名称:bagri,代码行数:16,代码来源:BagriXQJPlugin.java
示例19: initialValue
import javax.xml.xquery.XQConnection; //导入依赖的package包/类
@Override
protected TPoXQueryManagerTest initialValue() {
try {
XQConnection xqc = xqds.getConnection();
SchemaRepository xdm = ((BagriXQDataFactory) xqc).getProcessor().getRepository();
TPoXQueryManagerTest xqmt = new TPoXQueryManagerTest(xdm);
logger.info("initialValue.exit; XDM: {}", xdm);
return xqmt;
} catch (XQException ex) {
logger.error("", ex);
return null;
}
}
开发者ID:dsukhoroslov,项目名称:bagri,代码行数:14,代码来源:BagriDBPlugin.java
示例20: testSaxon
import javax.xml.xquery.XQConnection; //导入依赖的package包/类
@Test
public void testSaxon() throws XQException {
SaxonXQDataSource xqds = new SaxonXQDataSource();
XQConnection xqc = xqds.getConnection();
XQExpression xqe = xqc.createExpression();
XQSequence xqs = xqe.executeQuery("<e>Hello world!</e>");
//XQSequence xqs = xqe.executeQuery("<a b='c'>{5+2}</a>");
while (xqs.next()) {
System.out.println(xqs.getItemAsString(null));
}
//System.out.println(xqds.getSchemaValidationMode());
}
开发者ID:dsukhoroslov,项目名称:bagri,代码行数:13,代码来源:SaxonParserTest.java
注:本文中的javax.xml.xquery.XQConnection类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论