Examples of CobarClientInternalRouter

com.alibaba.cobar.client.router.CobarClientInternalRouter
CobarInternalRouter is the default router that will be used in cobar client, but it will not be the only one.
if it can't meet the needs, we can provide other {@link ICobarRouter} like aone that use rule engines.
for now, CobarInternalRouter will hold 4 set of routing rules:
1. sqlActionShardingRules
3. sqlActionRules
5. namespaceShardingRules
7. namespaceRules
rules start with "sqlAction" are rules that will exactly match against the sql-map action id in the routing fact, while rules start with "namesapce" just match against the "namespace" part in the sql action id; we will match these rules in sequence against the routing fact, each later rule will be used as fall-back rule if former match fails.
To enhance the rule matching performance, we add a LRU cache, you can decide whether to use this cache by set the {@link #enableCache} property's value totrue or false.
@author fujohnwang @since 1.0

Examples of com.alibaba.cobar.client.router.CobarClientInternalRouter

        if (enableCache) {
            if (cacheSize <= 0) {
                setCacheSize(10000);
            }
        }
        this.router = new CobarClientInternalRouter(enableCache, cacheSize);


        final Set<IRoutingRule<IBatisRoutingFact, List<String>>> sqlActionShardingRules = new HashSet<IRoutingRule<IBatisRoutingFact, List<String>>>();
        final Set<IRoutingRule<IBatisRoutingFact, List<String>>> sqlActionRules = new HashSet<IRoutingRule<IBatisRoutingFact, List<String>>>();
        final Set<IRoutingRule<IBatisRoutingFact, List<String>>> namespaceShardingRules = new HashSet<IRoutingRule<IBatisRoutingFact, List<String>>>();
        final Set<IRoutingRule<IBatisRoutingFact, List<String>>> namespaceRules = new HashSet<IRoutingRule<IBatisRoutingFact, List<String>>>();

View Full Code Here

Examples of com.alibaba.cobar.client.router.CobarClientInternalRouter


    public void testAssemblingRulesNormally() throws Exception {
        factory.setConfigLocation(new ClassPathResource(
                "com/alibaba/cobar/client/router/config/normal_rule_fixture.xml"));
        factory.afterPropertiesSet();
        CobarClientInternalRouter router = (CobarClientInternalRouter) factory.getObject();
        List<Set<IRoutingRule<IBatisRoutingFact, List<String>>>> rules = router.getRuleSequences();
        assertTrue(CollectionUtils.isNotEmpty(rules));
        assertEquals(4, rules.size());
    }

View Full Code Here

Examples of com.alibaba.cobar.client.router.CobarClientInternalRouter

                new ClassPathResource(
                        "com/alibaba/cobar/client/router/config/normal_rule_fixture.xml"),
                new ClassPathResource(
                        "com/alibaba/cobar/client/router/config/normal_rule_fixture2.xml") });
        factory.afterPropertiesSet();
        CobarClientInternalRouter router = (CobarClientInternalRouter) factory.getObject();
        List<Set<IRoutingRule<IBatisRoutingFact, List<String>>>> rules = router.getRuleSequences();
        assertTrue(CollectionUtils.isNotEmpty(rules));
        assertEquals(4, rules.size());


        for (Set<IRoutingRule<IBatisRoutingFact, List<String>>> set : rules) {
            assertEquals(1, set.size());

View Full Code Here

Examples of com.alibaba.cobar.client.router.CobarClientInternalRouter

                new ClassPathResource(
                        "com/alibaba/cobar/client/router/config/normal_rule_fixture.xml"),
                new ClassPathResource(
                        "com/alibaba/cobar/client/router/config/normal_rule_fixture3.xml") });
        factory.afterPropertiesSet();
        CobarClientInternalRouter router = (CobarClientInternalRouter) factory.getObject();
        List<Set<IRoutingRule<IBatisRoutingFact, List<String>>>> rules = router.getRuleSequences();
        assertTrue(CollectionUtils.isNotEmpty(rules));
        assertEquals(4, rules.size());


        assertEquals(1, rules.get(0).size());
        assertEquals(1, rules.get(1).size());

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.