Hi,

I am running 3 ignite nodes in a cluster and trying to connect using jdbc
thin driver with multiple end points and getting error when trying to get
connection. Here is my code for connecting to ignite cluster using jdbc thin
driver and multiple endpoints. Any help is appreciated

*Connection Pool Coniguration*

private static void initializeIgnitePool()
        {
                try
                {
                        
                        System.out.println("Configuring cache database 
connection pool");
//                      String
igniteUrl="jdbc:ignite:cfg://cache=default@file:$$home_path$$"+File.separator+"$$config_file_name$$";
//                      String
igniteUrl="jdbc:ignite:cfg://cache=default@file:/opt/apache-ignite-fabric-2.6.0-bin/config/icrm-ignite-config.xml";
                        String 
igniteUrl="jdbc:ignite:thin://192.168.0.117:10800,
192.168.0.62:10800, 192.168.0.115:10800";
                                        
                        BasicDataSource bds=new BasicDataSource();
                                
                                
                        
bds.setDriverClassName("org.apache.ignite.IgniteJdbcThinDriver");
                        bds.setUrl(igniteUrl);
//                              bds.setMaxActive(200);
//                              bds.setMaxWait(30);
                                bds.setMaxIdle(60);
                                bds.setTestOnBorrow(false);
                                bds.setLogAbandoned(false);
                                bds.setValidationQuery("select 1 ");
                                ds=bds;
                }
                catch(Exception e)
                {
                        e.printStackTrace();
                }
}


*Code for inserting multiple records*

for(int i=0;i<2000;i++)
                        {
                                try {
                                        Connection conn=pool.getConnection();
                                        PreparedStatement 
ps=conn.prepareStatement("insert into test1
(id,fname) values (?,?)");
                                        ps.setInt(1,i);
                                        ps.setString(2, "arpit-"+i);
                                        
                                        int u=ps.executeUpdate();
                                        System.out.println("Rows inserted :"+u);
                                        
                                        ps.close();
                                        conn.close();
                                        Thread.sleep(1000);
                                } catch (Exception e) {
                                        System.out.println(i+" ==============> 
"+e.getMessage()+"
<==========================");
                                }
                        }



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Reply via email to