• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java XQConnection类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了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;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java XmlStringBuilder类代码示例发布时间:2022-05-22
下一篇:
Java AddressingDispositionHelper类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap