I see there are couple of issues with the test
1) cache.query(new SqlFieldsQuery("alter table Person add column
\"Address.street\" as street varchar"));
- "as" is not supported in sql. So we should remove "as street" and it
should be like
cache.query(new SqlFieldsQuery("alter table Person add column
\"Address.street\" varchar"));
2) After making above change, it will work with / with out fix. But the
problem is with out the fix, if you have any other node joining this node,
it will not be able to join / query
I just tweaked your test code. PLease find the below one. main() is your
test class which will start one node.
a) Take this example and execute main() - this will start one node
b) now execute @Test method, this will start another node. You will get
attached exception ( exception.txt
<
http://apache-ignite-users.70518.x6.nabble.com/file/t2625/exception.txt> )
with out fix as by default it take alias as "street". But with fix it will
pass through, as it will create alias as "Address.street"
Please let me know if you need more clarification. Any quick help would be
appreciated. Thank you!
package my.ignite.cache.poc.index;
import org.apache.ignite.Ignite;
import org.apache.ignite.IgniteCache;
import org.apache.ignite.Ignition;
import org.apache.ignite.cache.query.SqlFieldsQuery;
import org.apache.ignite.configuration.CacheConfiguration;
import org.apache.ignite.configuration.IgniteConfiguration;
import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi;
import
org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder;
import org.junit.Test;
import java.util.Collections;
public class NestedIndexFieldTest {
public static void main(String args[]){
TcpDiscoverySpi discoverySpi = new TcpDiscoverySpi()
.setIpFinder(new
TcpDiscoveryVmIpFinder().setAddresses(Collections.singleton("127.0.0.1:47500..47509")));
IgniteConfiguration igniteConfig = new
IgniteConfiguration().setDiscoverySpi(discoverySpi);
Ignite ignite = Ignition.start(igniteConfig);
try{
IgniteCache<Object, Object> cache = ignite.createCache(new
CacheConfiguration<>("cache")
.setIndexedTypes(Integer.class, Person.class));
cache.put(1, new Person("john", new Address("baker", 221)));
System.err.println(cache.query(new SqlFieldsQuery("Select * from
Person")).getAll());
cache.query(new SqlFieldsQuery("alter table Person add column
name varchar"));
cache.query(new SqlFieldsQuery("alter table Person add column
address other"));
System.err.println(cache.query(new SqlFieldsQuery("Select * from
Person")).getAll());
cache.query(new SqlFieldsQuery("alter table Person add column
\"Address.street\" varchar"));
System.err.println(cache.query(new SqlFieldsQuery("Select * from
Person")).getAll());
cache.put(2, new Person("bill", new Address("green", 223)));
System.err.println(cache.query(new SqlFieldsQuery("Select * from
Person")).getAll());
} catch (Exception anyEx){
}
}
@Test
public void test(){
TcpDiscoverySpi discoverySpi = new TcpDiscoverySpi()
.setIpFinder(new
TcpDiscoveryVmIpFinder().setAddresses(Collections.singleton("127.0.0.1:47500..47509")));
IgniteConfiguration igniteConfig = new
IgniteConfiguration().setDiscoverySpi(discoverySpi);
try(Ignite ignite = Ignition.start(igniteConfig)){
IgniteCache<Object, Object> cache = ignite.getOrCreateCache(new
CacheConfiguration<>("cache")
.setIndexedTypes(Integer.class, Person.class));
System.err.println(cache.query(new SqlFieldsQuery("Select * from
Person")).getAll());
}
}
}
class Person {
String name;
Address address;
Person(String name, Address address){
this.name = name;
this.address = address;
}
@Override
public String toString() {
return "Person{" +
"name='" + name + '\'' +
", address=" + address +
'}';
}
}
class Address {
String street;
int number;
public Address(String street, int number){
this.street = street;
this.number = number;
}
@Override
public String toString() {
return "Address{" +
"street='" + street + '\'' +
", number=" + number +
'}';
}
}
--
Sent from:
http://apache-ignite-users.70518.x6.nabble.com/
Locked
