this is making no sense. There is absolutely nothing in the documentation
that says remove those items from the configuration. All i am looking for is
an example of a table that can be loaded with the data streamer without the
data ending up outside of the table. I have tried with and without that
simple mapper in th config and it makes no difference.
simple example i have:
1) config (has no caches specified - contents placed at the end)
2) create table in jdbc
CREATE TABLE IF NOT EXISTS Testy (
id int,
name varchar,
PRIMARY KEY (id)
) WITH "template=partitioned,backups=0";
3) table is visible in ignite
{
"successStatus": 0,
"error": null,
"sessionToken": null,
"response": [
{
"cacheName": "SQL_PUBLIC_TESTY",
"types": [
"SQL_PUBLIC_TESTY_07052f5a_37ac_4992_8a19_79da93e3df8a"
],
"keyClasses": {
"SQL_PUBLIC_TESTY_07052f5a_37ac_4992_8a19_79da93e3df8a":
"java.lang.Integer"
},
"valClasses": {
"SQL_PUBLIC_TESTY_07052f5a_37ac_4992_8a19_79da93e3df8a":
"java.lang.Object"
},
"fields": {
"SQL_PUBLIC_TESTY_07052f5a_37ac_4992_8a19_79da93e3df8a": {
"ID": "java.lang.Integer",
"NAME": "java.lang.String"
}
},
"indexes": {
"SQL_PUBLIC_TESTY_07052f5a_37ac_4992_8a19_79da93e3df8a": []
}
}}}
4) simple .net project
public class Testy
{
[QuerySqlField]
public int id { get; set; }
[QuerySqlField]
public string name { get; set; }
}
var cfg = new IgniteConfiguration()
{
SpringConfigUrl = @"C:\Cluster-client.xml"
};
var ignite = Ignition.Start(cfg);
using (var ldr = ignite.GetDataStreamer<int,
Testy>("SQL_PUBLIC_TESTY"))
{
ldr.AddData(1, new Testy() {id=1, name = "ffff" });
}
5) db beaver
SELECT count(*) FROM testy (result is 0)
6) rest query
http://127.0.0.1:8080/ignite?cmd=get&cacheName=SQL_PUBLIC_TESTY&keyType=int&key=1
{
"successStatus": 0,
"affinityNodeId": "9a006702-e11e-4fdc-bf84-7f0b28fc498f",
"error": null,
"sessionToken": null,
"response": {
"name": "ffff",
"id": 1
}
}
-----------------
config file
<beans xmlns="http://www.springframework.org/schema/beans";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xmlns:util="http://www.springframework.org/schema/util";
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/util
http://www.springframework.org/schema/util/spring-util.xsd";>
<bean class="org.apache.ignite.configuration.IgniteConfiguration">
<property name="clientMode" value="true"/>
<property name="igniteInstanceName" value="Cluster"/>
<property name="discoverySpi">
<bean
class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi">
<property name="ipFinder">
<bean
class="org.apache.ignite.spi.discovery.tcp.ipfinder.multicast.TcpDiscoveryMulticastIpFinder">
<property name="addresses">
<list>
<value>127.0.0.1:47500..47510</value>
</list>
</property>
</bean>
</property>
</bean>
</property>
<property name="binaryConfiguration">
<bean
class="org.apache.ignite.configuration.BinaryConfiguration">
<property name="nameMapper">
<bean
class="org.apache.ignite.binary.BinaryBasicNameMapper">
<property name="simpleName" value="true"/>
</bean>
</property>
</bean>
</property>
<property name="dataStorageConfiguration">
<bean
class="org.apache.ignite.configuration.DataStorageConfiguration">
<property name="defaultDataRegionConfiguration">
<bean
class="org.apache.ignite.configuration.DataRegionConfiguration">
<property name="maxSize" value="3145728000"/>
<property name="persistenceEnabled" value="true"/>
</bean>
</property>
</bean>
</property>
</bean>
</beans>
--
Sent from: http://apache-ignite-developers.2346864.n4.nabble.com/
