Developer's Scratchpad

HBASE - A POC

noreply@blogger.com (Rambros) — Sat, 03 Aug 2013 06:54:00 +0000

I have been exploring HBASE for its speedy retrieve and shipment. Although i had problems in bulk import,export feature, i was able to do few things like creating table, selecting records etc.

Main.java

import java.io.IOException;
import java.util.Arrays;
import java.util.List;
import org.apache.hadoop.conf.Configuration;

import org.apache.hadoop.fs.Path;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.HColumnDescriptor;
import org.apache.hadoop.hbase.HTableDescriptor;
import org.apache.hadoop.hbase.client.Delete;
import org.apache.hadoop.hbase.client.Get;
import org.apache.hadoop.hbase.client.HBaseAdmin;
import org.apache.hadoop.hbase.client.HTable;
import org.apache.hadoop.hbase.client.HTableFactory;
import org.apache.hadoop.hbase.client.HTableInterface;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.ResultScanner;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.client.coprocessor.AggregationClient;
import org.apache.hadoop.hbase.filter.BinaryComparator;
import org.apache.hadoop.hbase.filter.CompareFilter.CompareOp;
import org.apache.hadoop.hbase.filter.Filter;
import org.apache.hadoop.hbase.filter.FilterList;
import org.apache.hadoop.hbase.filter.FilterList.Operator;
import org.apache.hadoop.hbase.filter.PrefixFilter;
import org.apache.hadoop.hbase.filter.QualifierFilter;
import org.apache.hadoop.hbase.io.ImmutableBytesWritable;
import org.apache.hadoop.hbase.util.Bytes;
//import org.apache.hadoop.mapred.KeyValueTextInputFormat;
//import org.apache.hadoop.mapreduce.Job;
//import org.apache.hadoop.mapreduce.lib.input.FileInputFormat;
import org.apache.hadoop.mapred.KeyValueTextInputFormat;
import org.apache.hadoop.mapreduce.Job;
import org.apache.hadoop.mapreduce.Mapper;
import org.apache.hadoop.mapreduce.lib.input.FileInputFormat;
import org.apache.hadoop.hbase.mapreduce.HFileOutputFormat;
import org.apache.hadoop.hbase.mapreduce.PutSortReducer;
import org.apache.hadoop.hbase.mapreduce.TableOutputFormat;
import org.apache.hadoop.hbase.mapreduce.hadoopbackport.TotalOrderPartitioner;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.lib.input.TextInputFormat;
public class Main {

    /**
     * @param args the command line arguments
     */
    public static void main(String[] args) throws IOException, Throwable {
        // TODO code application logic here
        Configuration conf = HBaseConfiguration.create();
        conf.set("hbase.zookeeper.quorum", "192.168.1.96");
        //conf.set("hbase.zookeeper.property.clientPort", "2181");
//        // HBaseConfiguration conf = new HBaseConfiguration();
//        //   conf.addResource(new Path("/mnt/hbase-0.94.5/hbase-0.94.5/conf/hbase-site.xml"));
//        HTable table = new HTable(conf, "test_table");
//        Put put = new Put(Bytes.toBytes("test-key"));
//        put.add(Bytes.toBytes("columnfamily"), Bytes.toBytes("columnqualifier"), Bytes.toBytes("sample value"));
//        table.put(put);
////        Get g = new Get(Bytes.toBytes("test-key"));
////        Result r = table.get(g);
////        byte[] value = r.getValue(Bytes.toBytes("columnfamily"), Bytes.toBytes("columnqualifier"));
////// If we convert the value bytes, we should get back 'Some Value', the
////// value we inserted at this location.
////        String valueStr = Bytes.toString(value);
////        System.out.println("GET: " + valueStr);
//

        bulk(conf);
        //createTbl(conf);
        // Sample sample = new Sample();
        //sample.run(conf);
    }

    private static void createTbl(Configuration conf) throws Throwable {
        try {
            HBaseAdmin admin = new HBaseAdmin(conf);
            HTableDescriptor desc = new HTableDescriptor("workingtable".getBytes());
            desc.addFamily(new HColumnDescriptor("family1".getBytes()));
            desc.addFamily(new HColumnDescriptor("family1".getBytes()));
            admin.createTable(desc);

            HTableFactory factory = new HTableFactory();
            HTableInterface table = factory.createHTableInterface(conf, "workingtable".getBytes());
            createRecord(conf, table, admin);
            scan(admin, table);
            get(admin, table, conf);
            filters(admin, table);
            deleteRecord(admin, table);
            deleteTable(admin);
        } catch (Exception er) {
            er.printStackTrace();
        }

    }

    private static void createRecord(Configuration conf, HTableInterface table, HBaseAdmin admin) {
        try {
            Put p = new Put("Row1".getBytes());
            p.add("family1".getBytes(), "qualifier1".getBytes(), "raghuram".getBytes());
            p.add("family1".getBytes(), "qualifier2".getBytes(), "Gopal".getBytes());
            table.put(p);

            // Row2 => Family1:Qualifier1, Family2:Qualifier3
            p = new Put("Row2".getBytes());
            p.add("family1".getBytes(), "qualifier1".getBytes(), "sreeram".getBytes());
            p.add("family1".getBytes(), "qualifier2".getBytes(), "Heman".getBytes());
            table.put(p);
//
//            // Row3 => Family1:Qualifier1, Family2:Qualifier3
//            p = new Put(row3);
//            p.add(family1, qualifier1, cellData);
//            p.add(family2, qualifier3, cellData);
//            table.put(p);

//            admin.disableTable("workingtable");

            //          HColumnDescriptor desc = new HColumnDescriptor("Row1");
            //         admin.addColumn("workingtable", desc);

            //       admin.enableTable("workingtable");

        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    private static void scan(HBaseAdmin admin, HTableInterface table) {
        System.out.println("Scan method................");
        try {
            Scan scan = new Scan();
            scan.addColumn("family1".getBytes(), "qualifier1".getBytes());

            ResultScanner scanner = table.getScanner(scan);
            try {
                for (Result result : scanner) {
                    System.out.println("result row---->\n" + result);
                }
            } finally {
                scanner.close();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }

    }

    private static void get(HBaseAdmin admin, HTableInterface table, Configuration conf) throws Throwable {

        System.out.println("Get Method...............");
        try {
            Get g = new Get("Row1".getBytes());
            Result r = table.get(g);
            byte[] value = r.getValue("family1".getBytes(), "qualifier1".getBytes());

            System.out.println("Fetched value: " + Bytes.toString(value));

            AggregationClient aggregationClient = new AggregationClient(conf);
            Scan scan = new Scan();
            scan.addFamily("family1".getBytes());
            long rowCount = aggregationClient.rowCount("workingtable".getBytes(), null, scan);
            System.out.println("row count is " + rowCount);

        } catch (Exception e) {
            e.printStackTrace();

        }

    }

    private static void filters(HBaseAdmin admin, HTableInterface table) throws IOException {
        System.out.println("\n*** FILTERS ~ scanning with filters to fetch a row of which key is larget than \"Row1\"~ ***");
        try {
            Filter filter1 = new PrefixFilter("Row2".getBytes());
            Filter filter2 = new QualifierFilter(CompareOp.GREATER_OR_EQUAL, new BinaryComparator("qualifier1".getBytes()));

            List<Filter> filters = Arrays.asList(filter1, filter2);
            Filter filter3 = new FilterList(Operator.MUST_PASS_ALL, filters);

            Scan scan = new Scan();
            scan.setFilter(filter3);

            ResultScanner scanner = table.getScanner(scan);
            try {
                int i = 0;
                for (Result result : scanner) {
                    System.out.println("Filter " + scan.getFilter() + " matched row: " + result);
                    i++;
                }
                assert i == 1 : "This filtering sample should return 1 row but was " + i + ".";
            } finally {
                scanner.close();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }

    }

    private static void deleteRecord(HBaseAdmin admin, HTableInterface table) {
        System.out.println("inside delte record logic");
        try {
            Delete delete = new Delete("Row1".getBytes());
            delete.deleteColumn("family1".getBytes(), "qualifier1".getBytes());
            table.delete(delete);

            Get get = new Get("Row1".getBytes());
            Result result = table.get(get);
            byte[] value = result.getValue("family1".getBytes(), "qualifier1".getBytes());
            System.out.println("Fetch the data after delete: " + Bytes.toString(value));
        } catch (Exception e) {
            e.printStackTrace();
        }

    }

    private static void deleteTable(HBaseAdmin admin) throws IOException {
        System.out.println("inside delte table method.............");
        try {
            if (admin.tableExists("workingtable")) {
                admin.disableTable("workingtable");
                try {
                    admin.deleteTable("workingtable");
                } finally {
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }

    }

//    private static void bulkload(Configuration conf) {
//        try {
//            conf.set(TableOutputFormat.OUTPUT_TABLE, "crudtable");
//            Path inputPath = new Path("/share/tsvtest.tsv");
//
//            Job job = new Job(conf, "Sample job");
//
//            job.setMapOutputKeyClass(mapperKey);
//            job.setMapOutputValueClass(mapperValue);
//
//            FileInputFormat.setInputPaths(job, inputPath);
//            job.setInputFormatClass(KeyValueTextInputFormat.class);
//            FileOutputFormat.setOutputPath(job, new Path(HFileoutputPath));
////directory at HDFS where HFiles will be placed
////before bulk loading
//
//            job.setOutputFormatClass(HFileOutputFormat.class);
//
//            job.setJarByClass(caller);
//            job.setMapperClass(mapper);
//
//            HTable hTable = new HTable(config, tableNAME); //tableNAME is a String representing a table which has to already exist in HBase
//            HFileOutputFormat.configureIncrementalLoad(job, hTable);
////check respective API for the complete functionality of this function
//
//job.waitForCompletion(true);
//
//            /* after the job's completion, we have to write the HFiles
//             * into HBase's specified table */
//            LoadIncrementalHFiles lihf = new LoadIncrementalHFiles(config);
//            lihf.doBulkLoad(new Path(HFileoutputPath), hTable);
//        } catch (Exception e) {
//            e.printStackTrace();
//        }
//    }
    private static void bulk(Configuration conf) throws Exception {
        // conf.set(TableOutputFormat.OUTPUT_TABLE, "crudtable");
        Job job = new Job(conf, "bulk-load");

        job.setJarByClass(Main.class);
        job.setMapperClass(BulkLoadHBase_1Mapper.class);

        job.setReducerClass(PutSortReducer.class);
        job.setMapOutputKeyClass(ImmutableBytesWritable.class);
        job.setMapOutputValueClass(Put.class);
        job.setPartitionerClass(TotalOrderPartitioner.class);
        job.setInputFormatClass(TextInputFormat.class);
        job.setOutputFormatClass(HFileOutputFormat.class);

        FileInputFormat.addInputPath(job,
                new Path("/share/raghu/bulkLoad.csv"));
        HFileOutputFormat.setOutputPath(job,
                new Path("/share/raghu/HBASE_BulkOutput/"));
        Configuration hConf = HBaseConfiguration.create(conf);
        hConf.set("hbase.zookeeper.quorum", "192.168.1.96");
        //hConf.set("hbase.zookeeper.property.clientPort", hbaseZookeeperClientPort);

        HTable hTable = new HTable(hConf, "crudtable");

        HFileOutputFormat.configureIncrementalLoad(job, hTable);
      // return job;
        System.exit(job.waitForCompletion(true) ? 0 : 1);
    }

    public static class BulkLoadHBase_1Mapper
            extends Mapper<Text, Text, ImmutableBytesWritable, Put> {

        public void map(Text key, Text value, Context context) throws IOException, InterruptedException {

            System.out.println("KEY " + key.toString());
            System.out.println("VALUES : " + value);
            System.out.println("Context : " + context);

            ImmutableBytesWritable ibw =
                    new ImmutableBytesWritable(Bytes.toBytes(key.toString()));

            String val = value.toString();
            byte[] b = Bytes.toBytes(val);
            Put p = new Put(Bytes.toBytes(key.toString()));

            p.add(Bytes.toBytes("family1"), Bytes.toBytes("qualifier1"), Bytes.toBytes(val));

            context.write(ibw, p);
        }
    }
}

http://hbase.apache.org/book/perf.writing.html

Country Restriction, Java

noreply@blogger.com (Rambros) — Sat, 03 Aug 2013 06:40:00 +0000

There are scenario's where we don't want our application to be accessed from differnt zone or differnt country apart from where we have installed. I came across a following sample in the internet which does that,

locationservlet.java

import java.io.IOException;
import java.io.PrintWriter;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.net.InetAddress;
import javaQuery.j2ee.GeoLocation;

/**
*
* @author defender
*/
public class locationservlet extends HttpServlet {

    /**
     * Processes requests for both HTTP <code>GET</code> and <code>POST</code> methods.
     * @param request servlet request
     * @param response servlet response
     * @throws ServletException if a servlet-specific error occurs
     * @throws IOException if an I/O error occurs
     */
    protected void processRequest(HttpServletRequest request, HttpServletResponse response)
            throws ServletException, IOException {
        response.setContentType("text/html;charset=UTF-8");
        PrintWriter out = response.getWriter();
        try {
            /* TODO output your page here
            out.println("<html>");
            out.println("<head>");
            out.println("<title>Servlet locationservlet</title>");
            out.println("</head>");
            out.println("<body>");
            out.println("<h1>Servlet locationservlet at " + request.getContextPath () + "</h1>");
            out.println("</body>");
            out.println("</html>");
             */
            request.getHeader("VIA");
            String ipAddress = request.getHeader("X-FORWARDED-FOR");
            System.out.println("request.getHeader(X-FORWARDED-FOR)----" + request.getHeader("X-FORWARDED-FOR"));
            System.out.println("request" + request.getRemoteAddr());
            if (ipAddress == null) {
                ipAddress = request.getRemoteAddr();
            }
            System.out.println("ipAddress---->" + ipAddress);
            InetAddress thisIP = InetAddress.getByName(ipAddress);
            GeoLocation gl = new GeoLocation();
            GeoLocation gl1 = new GeoLocation();
            gl.GetGeoLocationByIP(request.getRemoteAddr());
            System.out.println("coun------>" + gl.Country);

            gl1.GetGeoLocation(thisIP);
            String country = gl.Country;
            String country1 = gl1.Country;
            System.out.println("country----------------" + country);
            System.out.println("country1----------------" + country1);
            out.println("country--->" + country);
            out.println("country 1--->" + country1);
        } finally {
            out.close();
        }
    }

    // <editor-fold defaultstate="collapsed" desc="HttpServlet methods. Click on the + sign on the left to edit the code.">
    /**
     * Handles the HTTP <code>GET</code> method.
     * @param request servlet request
     * @param response servlet response
     * @throws ServletException if a servlet-specific error occurs
     * @throws IOException if an I/O error occurs
     */
    @Override
    protected void doGet(HttpServletRequest request, HttpServletResponse response)
            throws ServletException, IOException {
        processRequest(request, response);
    }

    /**
     * Handles the HTTP <code>POST</code> method.
     * @param request servlet request
     * @param response servlet response
     * @throws ServletException if a servlet-specific error occurs
     * @throws IOException if an I/O error occurs
     */
    @Override
    protected void doPost(HttpServletRequest request, HttpServletResponse response)
            throws ServletException, IOException {
        processRequest(request, response);
    }

    /**
     * Returns a short description of the servlet.
     * @return a String containing servlet description
     */
    @Override
    public String getServletInfo() {
        return "Short description";
    }// </editor-fold>
}

Please refer the following website for php code sample, it is self explanatory .

http://www.coderewind.com/article/find-a-visitors-ip-address-with-country-and-flag-in-php/

http://phpweby.com/software/ip2country

For .net :

http://aspboss.blogspot.in/2010/05/how-to-get-visitors-countrylongitudelat.html

Delta cloud Java API integration

noreply@blogger.com (Rambros) — Sat, 03 Aug 2013 06:17:00 +0000

In my previous post i would given you an idea of what delta cloud is about. In this post we will see the integration of delta cloud api in java . The example makes use of openstack integrated deltacloud.

Main.java :

import sun.misc.BASE64Encoder;

public class Main {

    /**
     * @param args the command line arguments
     */
    public static void main(String[] args) {
        // TODO code application logic here

        try {

            DeltaAPICall deltaapi = new DeltaAPICall();

            String url = "";
            String auth = "";
            String result = "";

            BASE64Encoder enc = new sun.misc.BASE64Encoder();
            //--- The below username and password is openstack user credential --//
            String userpassword = "appteam@corenttech.com+Appteam:corent.123$";
            auth = enc.encode(userpassword.getBytes());
            auth = "Basic "+auth;
            System.out.println("auth >>> "+auth);
            //For Ex: auth = "Basic YXBwdGVhbUBjb3JlbnR0ZWNoLmNvbStBcHB0ZWFtOmNvcmVudC4xMjMk";


            //--- Below lines to list the api's using openstack user crendetail in deltacloud server machine ---//
            System.out.println("\n--------------API'S---------------------");
            url = "http://192.168.1.102:3001/api?format=xml";
            result = deltaapi.getDeltaAPI(url, auth);
            System.out.println("\n API's Final Result >>>> \n" + result);
            System.out.println("######################################");

            //--- Below lines to list the images using openstack user crendetail in deltacloud server machine ---//
            System.out.println("\n--------------ALL IMAGES-----------------");
            url = "http://192.168.1.102:3001/api/images?format=xml";
            result = deltaapi.getDeltaAllImages(url, auth);
            System.out.println("\n All Images Final Result >>>> \n" + result);
            System.out.println("######################################");

            //--- Below lines to list the hardware profiles using openstack user crendetail in deltacloud server machine ---//
            System.out.println("\n--------------ALL HARDWARE PROFILES[FLAVORS]-----------------");
            url = "http://192.168.1.102:3001/api/hardware_profiles?format=xml";
            result = deltaapi.getDeltaProfile(url, auth);
            System.out.println("\n Hardware Profiles Final Result >>>> \n" + result);
            System.out.println("######################################");

            //--- Below lines to list the instances using openstack user crendetail in deltacloud server machine ---//
            System.out.println("\n--------------ALL INSTANCES-----------------");
            url = "http://192.168.1.102:3001/api/instances?format=xml";
            result = deltaapi.getDeltaAllInstances(url, auth);
            System.out.println("\n All Instances Final Result >>>> \n" + result);
            System.out.println("######################################");

            //--- Below lines to create the instnace using openstack user crendetail in deltacloud server machine ---//
            System.out.println("\n--------------LAUNCH INSTANCE-----------------");
            url = "http://192.168.1.102:3001/api/instances?format=xml";
            String image_id = "";
            String hwp_id = "";
            String keyname = "";
            result = deltaapi.launchDeltaInstance(url, auth, image_id, hwp_id, keyname );
            System.out.println("\n Instance Final Result >>>> \n" + result);
            System.out.println("######################################");

            //--- Below lines to reboot the instnace using openstack user crendetail in deltacloud server machine ---//
            System.out.println("\n--------------REBOOT INSTANCE-----------------");
            String instance_id = "";
            url = "http://192.168.1.102:3001/api/instances/"+instance_id+"/reboot?format=xml";
            result = deltaapi.rebootDeltaInstnace(url, auth);
            System.out.println("\n Reboot Instance Final Result >>>> \n" + result);
            System.out.println("######################################");

             //--- Below lines to stop the instnace using openstack user crendetail in deltacloud server machine ---//
            System.out.println("\n--------------STOP INSTANCE[DELETE]-----------------");
            url = "http://192.168.1.102:3001/api/instances/"+instance_id+"/stop?format=xml";
            result = deltaapi.stopDeltaInstnace(url, auth);
            System.out.println("\n Stop Instance Final Result >>>> \n" + result);
            System.out.println("######################################");

            //--- Below lines to create the image instnace using openstack user crendetail in deltacloud server machine ---//
            System.out.println("\n--------------CREATE IMAGE INSTANCE-----------------");
            url = "http://192.168.1.102:3001/api/images?format=xml";
            String image_name = "DeltaCloud_Image1";
            result = deltaapi.createDeltaImageInstnace(url, auth, instance_id, image_name);
            System.out.println("\n Create Images Instance Final Result >>>> \n" + result);
            System.out.println("######################################");

            //--- Below lines to delete the image using openstack user crendetail in deltacloud server machine ---//
            System.out.println("\n--------------DELETE IMAGE-----------------");
            url = "http://192.168.1.102:3001/api/images/"+image_id+"?format=xml";
            result = deltaapi.delteDeltaImage(url, auth);
            System.out.println("\n Images Final Result >>>> \n" + result);
            System.out.println("######################################");

            //--- Below lines to list the volumes using openstack user crendetail in deltacloud server machine ---//
            System.out.println("\n--------------ALL VOLUMES-----------------");
            url = "http://192.168.1.102:3001/api/storage_volumes?format=xml";
            result = deltaapi.getDeltaAllVolumes(url, auth);
            System.out.println("\n All Volumes Final Result >>>> \n" + result);
            System.out.println("######################################");

            //--- Below lines to create a volume using openstack user crendetail in deltacloud server machine ---//
            System.out.println("\n----------------CREATE VOLUME-------------------");
            String name = "";
            String capacity = "";
            String realm_id = "";
            url = "http://192.168.1.102:3001/api/storage_volumes?format=xml";
            result = deltaapi.createDeltaVolume(url, auth, name, capacity, realm_id);
            System.out.println("\n Create Volume Final Result >>>> \n" + result);
            System.out.println("######################################");

            //--- Below lines to delete the specified volume using openstack user crendetail in deltacloud server machine ---//
            System.out.println("\n----------------DELETE VOLUME-------------------");
            String volume_id = "";
            url = "http://192.168.1.102:3001/api/storage_volumes/"+volume_id+"?format=xml";
            result = deltaapi.deleteDeltaVolume(url, auth);
            System.out.println("\n Delete Volume Final Result >>>> \n" + result);
            System.out.println("######################################");

            //--- Below lines to create a volume attachment using openstack user crendetail in deltacloud server machine ---//
            System.out.println("\n----------------CREATE VOLUME ATTACHMENT-------------------");
            String device = "/dev/sdi";
            url = "http://192.168.1.102:3001/api/storage_volumes/"+volume_id+"/attach?format=xml";
            result = deltaapi.atttachDeltaVolume(url, auth, instance_id, device);
            System.out.println("\n Create Volume Attachment Final Result >>>> \n" + result);
            System.out.println("######################################");

            //--- Below lines to create a snapshot volume using openstack user crendetail in deltacloud server machine ---//
            //System.out.println("\n----------------CREATE SNAPSHOT VOLUME-------------------");
            //url = "http://192.168.1.102:3001/api/storage_snapshots?format=xml";
            //result = deltaapi.createDeltasnapshotVolume(url, auth, volume_id);
            //System.out.println("\n Create Snapshot Volume Final Result >>>> \n" + result);
            //System.out.println("######################################");

            //--- Below lines to list the instnace states using openstack user crendetail in deltacloud server machine ---//
            System.out.println("\n--------------INSTANCE STATES-----------------");
            url = "http://192.168.1.102:3001/api/instance_states?format=xml";
            result = deltaapi.getDeltaInstnacestates(url, auth);
            System.out.println("\n Instance States Final Result >>>> \n" + result);
            System.out.println("######################################");



        } catch (Exception e) {
            e.printStackTrace();
        }
    }

}

DeltaAPICall .java :

public class DeltaAPICall {

    private CloudAPICall cloudapi = null;

    public DeltaAPICall()
    {
        cloudapi = new CloudAPICall();
    }

    /**
     * This method will fetch the all available api service in deltacloud server machine
     * @param url
     * @param Authentication
     * @return
     */
    public String getDeltaAPI(String url, String Authentication)
    {
        String result = "";
        result = cloudapi.getAPI(url, Authentication);
        return result;
    }

    /**
     * This method will fetch the all images in deltacloud server machine
     * @param url
     * @param Authentication
     * @return
     */
    public String getDeltaAllImages(String url, String Authentication)
    {
        String result = "";
        result = cloudapi.getAllImages(url, Authentication);
        return result;
    }

    /**
     * This method will fetch the all hardware profiles in deltacloud server machine
     * @param url
     * @param Authentication
     * @return
     */
    public String getDeltaProfile(String url, String Authentication)
    {
        String result = "";
        result = cloudapi.getHardwareProfiles(url, Authentication);
        return result;
    }

    /**
     * This method will fetch the all instances in deltacloud server machine
     * @param url
     * @param Authentication
     * @return
     */
    public String getDeltaAllInstances(String url, String Authentication)
    {
        String result = "";
        result = cloudapi.getAllInstances(url, Authentication);
        return result;
    }

    /**
     * This method will launch the instance using specified parameters in deltacloud server machine
     * @param url
     * @param Authentication
     * @param image_id
     * @param hwp_id
     * @param keyname
     * @return
     */
    public String launchDeltaInstance(String url, String Authentication, String image_id, String hwp_id, String keyname)
    {
        String result = "";
        result = cloudapi.launchInstance(url, Authentication, image_id, hwp_id, keyname);
        return result;
    }

    /**
     * This method will reboot the specified instance in deltacloud server machine
     * @param url
     * @param Authentication
     * @return
     */
    public String rebootDeltaInstnace(String url, String Authentication)
    {
        String result = "";
        result = cloudapi.rebootInstance(url, Authentication);
        return result;
    }

    /**
     * This method will stop the spcified instance in deltacloud server machine
     * @param url
     * @param Authentication
     * @return
     */
    public String stopDeltaInstnace(String url, String Authentication)
    {
        String result = "";
        result = cloudapi.stopInstance(url, Authentication);
        return result;
    }

    /**
     * This method will create the image instance using specified below parameters in deltacloud server machine
     * @param url
     * @param Authentication
     * @param instance_id
     * @param image_name
     * @return
     */
    public String createDeltaImageInstnace(String url, String Authentication, String instance_id, String image_name)
    {
        String result = "";
        result = cloudapi.createImageInstance(url, Authentication, instance_id, image_name);
        return result;
    }

    /**
     * This method will delete the specified image in deltacloud server machine
     * @param url
     * @param Authentication
     * @return
     */
    public String delteDeltaImage(String url, String Authentication)
    {
        String result = "";
        result = cloudapi.deleteImage(url, Authentication);
        return result;
    }

    /**
     * This method will fetch the all volumes in deltacloud server machine
     * @param url
     * @param Authentication
     * @return
     */
    public String getDeltaAllVolumes(String url, String Authentication)
    {
        String result = "";
        result = cloudapi.getAllVolumes(url, Authentication);
        return result;
    }

    /**
     * This method will create the volume using specified parameters in deltacloud server machine
     * @param url
     * @param Authentication
     * @param name
     * @param capacity
     * @param realm_id
     * @return
     */
    public String createDeltaVolume(String url, String Authentication, String name, String capacity, String realm_id)
    {
        String result = "";
        result = cloudapi.createVolume(url, Authentication, name, capacity, realm_id);
        return result;
    }

    /**
     * This method will delete the specified volume in deltacloud server machine
     * @param url
     * @param Authentication
     * @return
     */
    public String deleteDeltaVolume(String url, String Authentication)
    {
        String result = "";
        result = cloudapi.deleteVolume(url, Authentication);
        return result;
    }

    /**
     * This method will attach the volume using specified parameters in deltacloud server machine
     * @param url
     * @param Authentication
     * @param instance_id
     * @param device
     * @return
     */
    public String atttachDeltaVolume(String url, String Authentication, String instance_id, String device)
    {
        String result = "";
        result = cloudapi.attachVolume(url, Authentication, instance_id, device);
        return result;
    }

    /**
     * This method will create the snapshot volume using volume_id in deltacloud server machine
     * @param url
     * @param Authentication
     * @param volume_id
     * @return
     */
    public String createDeltasnapshotVolume(String url, String Authentication, String volume_id)
    {
        String result = "";
        result = cloudapi.snapshotVolume(url, Authentication, volume_id);
        return result;
    }

    /**
     * This method will fetch the all available instance states in deltacloud server machine
     * @param url
     * @param Authentication
     * @return
     */
    public String getDeltaInstnacestates(String url, String Authentication)
    {
        String result = "";
        result = cloudapi.getInstanceStates(url, Authentication);
        return result;
    }
}

CloudAPICall.java

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.FileWriter;
import java.io.InputStreamReader;
import java.util.ArrayList;
import java.util.List;
import org.apache.http.NameValuePair;
import org.apache.http.HttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.client.HttpClient;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.HttpDelete;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.protocol.HTTP;

public class CloudAPICall {

    /**
     * This method will take url information , authentication and calls the deltacloud Gateways with GET method and list the all available services.
     * @param url
     * @param Authentication
     * @return
     */
    public String getAPI(String url, String Authentication) {
        String result = "";
        try {
            //String url = "http://192.168.1.102:3001/api?format=xml";

            System.out.println("\n url >>> " + url);
            System.out.println(" auth >>> " + Authentication);

            HttpClient client = new DefaultHttpClient();
            HttpGet request = new HttpGet(url);
            request.setHeader("Authorization", Authentication);
            HttpResponse httpResponse = client.execute(request);
            BufferedReader rd = new BufferedReader(new InputStreamReader(httpResponse.getEntity().getContent()));
            while (rd.readLine() != null) {
                result += rd.readLine();
            }
            System.out.println("\n Result >>> " + result);
        } catch (Exception e) {
            e.printStackTrace();
            result = "Caught in Exception";
        }
        return result;
    }

    /**
     * This method will take url information , authentication and calls the deltacloud Gateways with GET method and list the all images.
     * @param url
     * @param Authentication
     * @return
     */
    public String getAllImages(String url, String Authentication) {
        String result = "";

        try {
            //String url = "http://192.168.1.102:3001/api/images?format=xml";

            System.out.println("\n url >>> " + url);
            System.out.println(" auth >>> " + Authentication);

            HttpClient client = new DefaultHttpClient();
            HttpGet request = new HttpGet(url);
            request.setHeader("Authorization", Authentication);
            HttpResponse httpResponse = client.execute(request);
            BufferedReader rd = new BufferedReader(new InputStreamReader(httpResponse.getEntity().getContent()));
            while (rd.readLine() != null) {
                result += rd.readLine();
            }
            System.out.println("\n Result >>> " + result);
        } catch (Exception e) {
            e.printStackTrace();
            result = "Caught in Exception";
        }
        return result;
    }

    /**
     * This method will take url information , authentication and calls the deltacloud Gateways with GET method and list the all hardware profiles.
     * @param url
     * @param Authentication
     * @return
     */
    public String getHardwareProfiles(String url, String Authentication) {
        String result = "";
        try {
            //String url = "http://192.168.1.102:3001/api/hardware_profiles?format=xml";

            System.out.println("\n url >>> " + url);
            System.out.println(" auth >>> " + Authentication);

            HttpClient client = new DefaultHttpClient();
            HttpGet request = new HttpGet(url);
            request.setHeader("Authorization", Authentication);
            HttpResponse httpResponse = client.execute(request);

            BufferedReader rd = new BufferedReader(new InputStreamReader(httpResponse.getEntity().getContent()));
            while (rd.readLine() != null) {
                result += rd.readLine();
            }
            System.out.println("\n Result >>> " + result);
        } catch (Exception e) {
            e.printStackTrace();
            result = "Caught in Exception";
        }
        return result;
    }

    /**
     * This method will take url information , authentication and calls the deltacloud Gateways with GET method and list the all instances.
     * @param url
     * @param Authentication
     * @return
     */
    public String getAllInstances(String url, String Authentication) {
        String result = "";
        try {
            //String url = "http://192.168.1.102:3001/api/instances?format=xml";

            System.out.println("\n url >>> " + url);
            System.out.println(" auth >>> " + Authentication);

            HttpClient client = new DefaultHttpClient();
            HttpGet request = new HttpGet(url);

            request.setHeader("Authorization", Authentication);
            HttpResponse httpResponse = client.execute(request);

            BufferedReader rd = new BufferedReader(new InputStreamReader(httpResponse.getEntity().getContent()));
            while (rd.readLine() != null) {
                result += rd.readLine();
            }

            System.out.println("\n Result >>> " + result);
        } catch (Exception e) {
            e.printStackTrace();
            result = "Caught in Exception";
        }
        return result;
    }

    /**
     * This method will take url information,authentication,image_id,profile_id,keyname and calls the deltacloud Gateways with POST method and launch the instance.
     * @param url
     * @param Authentication
     * @param image_id
     * @param hwp_id
     * @param keyname
     * @return
     */
    public String launchInstance(String url, String Authentication, String image_id, String hwp_id, String keyname) {
        String result = "";

        try {
            //String url = "http://192.168.1.102:3001/api/instances?format=xml";

            System.out.println("\n url >>> " + url);
            System.out.println(" auth >>> " + Authentication);

            HttpClient client = new DefaultHttpClient();
            HttpPost request = new HttpPost(url);
            request.addHeader("Authorization", "Basic " + Authentication);

            List<NameValuePair> nvps = new ArrayList<NameValuePair>();
            nvps.add(new BasicNameValuePair("image_id", "09eb0769-e6f8-44c4-9875-59aaa1ddaa6c"));
            nvps.add(new BasicNameValuePair("hwp_id", "10"));
            nvps.add(new BasicNameValuePair("keyname", "deltaKey"));
            request.setEntity(new UrlEncodedFormEntity(nvps, HTTP.UTF_8));

            HttpResponse httpResponse = client.execute(request);
            System.out.println("httpResponse.getStatusLine().getStatusCode()---->>>>" + httpResponse.getStatusLine().getStatusCode());
            BufferedReader rd = new BufferedReader(new InputStreamReader(httpResponse.getEntity().getContent()));
            while (rd.readLine() != null) {
                result += rd.readLine();
            }

            System.out.println("\n Result >>> " + result);
        } catch (Exception e) {
            e.printStackTrace();
            result = "Caught in Exception";
        }
        return result;
    }

    /**
     * This method will take url information , authentication and calls the deltacloud Gateways with POST method and reboot the specified instance.
     * @param url
     * @param Authentication
     * @return
     */
    public String rebootInstance(String url, String Authentication) {
        String result = "";
        try {
            //String url = "http://192.168.1.102:3001/api/instances/8df2f3c6-52ff-46c9-acc6-3163baf64c06/reboot?format=xml";

            System.out.println("\n url >>> " + url);
            System.out.println(" auth >>> " + Authentication);

            HttpClient client = new DefaultHttpClient();
            HttpPost request = new HttpPost(url);
            request.addHeader("Authorization", Authentication);

            HttpResponse httpResponse = client.execute(request);
            System.out.println("httpResponse.getStatusLine().getStatusCode()---->>>>" + httpResponse.getStatusLine().getStatusCode());
            BufferedReader rd = new BufferedReader(new InputStreamReader(httpResponse.getEntity().getContent()));
            while (rd.readLine() != null) {
                result += rd.readLine();
            }
            System.out.println("\n Result >>> " + result);
        } catch (Exception e) {
            e.printStackTrace();
            result = "Caught in Exception";
        }
        return result;
    }

    /**
     * This method will take url information , authentication and calls the deltacloud Gateways with POST method and stop the specified instance.
     * @param url
     * @param Authentication
     * @return
     */
    public String stopInstance(String url, String Authentication) {
        String result = "";
        try {
            //String url = "http://192.168.1.102:3001/api/instances/8df2f3c6-52ff-46c9-acc6-3163baf64c06/stop?format=xml";

            System.out.println("\n url >>> " + url);
            System.out.println(" auth >>> " + Authentication);

            HttpClient client = new DefaultHttpClient();
            HttpPost request = new HttpPost(url);
            request.addHeader("Authorization", Authentication);

            HttpResponse httpResponse = client.execute(request);
            System.out.println("httpResponse.getStatusLine().getStatusCode()---->>>>" + httpResponse.getStatusLine().getStatusCode());
            BufferedReader rd = new BufferedReader(new InputStreamReader(httpResponse.getEntity().getContent()));
            while (rd.readLine() != null) {
                result += rd.readLine();
            }
            System.out.println("\n Result >>> " + result);
        } catch (Exception e) {
            e.printStackTrace();
            result = "Caught in Exception";
        }
        return result;
    }

    /**
     * This method will take url information,authentication,instance_id,image_name and calls the deltacloud Gateways with POST method and create the image instance.
     * @param url
     * @param Authentication
     * @param instance_id
     * @param image_name
     * @return
     */
    public String createImageInstance(String url, String Authentication, String instance_id, String image_name) {
        String result = "";
        try {
            //String url = "http://192.168.1.102:3001/api/images?format=xml";

            System.out.println("\n url >>> " + url);
            System.out.println(" auth >>> " + Authentication);

            HttpClient client = new DefaultHttpClient();
            HttpPost request = new HttpPost(url);
            request.addHeader("Authorization", Authentication);

            List<NameValuePair> nvps = new ArrayList<NameValuePair>();
            nvps.add(new BasicNameValuePair("instance_id", "8df2f3c6-52ff-46c9-acc6-3163baf64c06"));
            nvps.add(new BasicNameValuePair("name", "gopal-delta"));
            request.setEntity(new UrlEncodedFormEntity(nvps, HTTP.UTF_8));

            HttpResponse httpResponse = client.execute(request);
            System.out.println("httpResponse.getStatusLine().getStatusCode()---->>>>" + httpResponse.getStatusLine().getStatusCode());
            BufferedReader rd = new BufferedReader(new InputStreamReader(httpResponse.getEntity().getContent()));
            while (rd.readLine() != null) {
                result += rd.readLine();
            }
            System.out.println("\n Result >>> " + result);
        } catch (Exception e) {
            e.printStackTrace();
            result = "Caught in Exception";
        }
        return result;
    }

    /**
     * This method will take url information , authentication and calls the deltacloud Gateways with DELETE method and delete the specified image.
     * @param url
     * @param Authentication
     * @return
     */
    public String deleteImage(String url, String Authentication) {
        String result = "";
        try {
            //String url = "http://192.168.1.102:3001/api/images/29a74e07-8863-4855-9e12-21a7b28e0ff8?format=xml";

            System.out.println("\n url >>> " + url);
            System.out.println("tokid >>> " + Authentication);

            HttpClient httpClient = new DefaultHttpClient();
            HttpDelete del = new HttpDelete(url);
            del.addHeader("Authorization", Authentication);
            HttpResponse response = httpClient.execute(del);

            result = "Successfuly Instance Deleted.";
            System.out.println("\n Result >>> " + result);
        } catch (Exception e) {
            e.printStackTrace();
            result = "Caught in Exception";
        }
        return result;
    }

    /**
     * This method will take url information , authentication and calls the deltacloud Gateways with GET method and list the all volumes.
     * @param url
     * @param Authentication
     * @return
     */
    public String getAllVolumes(String url, String Authentication) {
        String result = "";
        try {
            //String url = "http://192.168.1.102:3001/api/storage_volumes?format=xml";

            System.out.println("\n url >>> " + url);
            System.out.println(" auth >>> " + Authentication);

            HttpClient client = new DefaultHttpClient();
            HttpGet request = new HttpGet(url);

            request.setHeader("Authorization", Authentication);
            HttpResponse httpResponse = client.execute(request);

            BufferedReader rd = new BufferedReader(new InputStreamReader(httpResponse.getEntity().getContent()));
            while (rd.readLine() != null) {
                result += rd.readLine();
            }
            System.out.println("\n Result >>> " + result);
        } catch (Exception e) {
            e.printStackTrace();
            result = "Caught in Exception";
        }
        return result;
    }

    /**
     * This method will take url information,authentication,name,capacity,realm_id and calls the deltacloud Gateways with POST method and create the volume.
     * @param url
     * @param Authentication
     * @param name
     * @param capacity
     * @param realm_id
     * @return
     */
    public String createVolume(String url, String Authentication, String name, String capacity, String realm_id) {
        String result = "";
        try {
            //String url = "http://192.168.1.102:3001/api/storage_volumes?format=xml";

            System.out.println("\n url >>> " + url);
            System.out.println(" auth >>> " + Authentication);

            HttpClient client = new DefaultHttpClient();
            HttpPost request = new HttpPost(url);
            request.addHeader("Authorization", Authentication);

            List<NameValuePair> nvps = new ArrayList<NameValuePair>();
            nvps.add(new BasicNameValuePair("name", "Vol1"));
            nvps.add(new BasicNameValuePair("capacity", "1"));
            nvps.add(new BasicNameValuePair("realm_id", "default"));
            request.setEntity(new UrlEncodedFormEntity(nvps, HTTP.UTF_8));

            HttpResponse httpResponse = client.execute(request);
            System.out.println("httpResponse.getStatusLine().getStatusCode()---->>>>" + httpResponse.getStatusLine().getStatusCode());
            BufferedReader rd = new BufferedReader(new InputStreamReader(httpResponse.getEntity().getContent()));
            while (rd.readLine() != null) {
                result += rd.readLine();
            }
            System.out.println("\n Result >>> " + result);
        } catch (Exception e) {
            e.printStackTrace();
            result = "Caught in Exception";
        }
        return result;
    }

    /**
     * This method will take url information , authentication and calls the deltacloud Gateways with DELETE method and delete the specified volume.
     * @param url
     * @param Authentication
     * @return
     */
    public String deleteVolume(String url, String Authentication) {
        String result = "";
        try {
            //String url = "http://192.168.1.102:3001/api/storage_volumes/7?format=xml";

            System.out.println("\n url >>> " + url);
            System.out.println(" auth >>> " + Authentication);

            HttpClient httpClient = new DefaultHttpClient();
            HttpDelete del = new HttpDelete(url);
            del.addHeader("Authorization", Authentication);

            HttpResponse httpResponse = httpClient.execute(del);
            System.out.println("httpResponse.getStatusLine().getStatusCode()---->>>>" + httpResponse.getStatusLine().getStatusCode());
            BufferedReader rd = new BufferedReader(new InputStreamReader(httpResponse.getEntity().getContent()));
            while (rd.readLine() != null) {
                result += rd.readLine();
            }
            System.out.println("\n Result >>> " + result);
        } catch (Exception e) {
            e.printStackTrace();
            result = "Caught in Exception";
        }
        return result;
    }

    /**
     * This method will take url information,authentication,instance_id,device and calls the deltacloud Gateways with POST method and attache the volume.
     * @param url
     * @param Authentication
     * @param instance_id
     * @param device
     * @return
     */
    public String attachVolume(String url, String Authentication, String instance_id, String device) {
        String result = "";
        try {
            //String url = "http://192.168.1.102:3001/api/storage_volumes/7/attach?format=xml";

            System.out.println("\n url >>> " + url);
            System.out.println(" auth >>> " + Authentication);

            HttpClient client = new DefaultHttpClient();
            HttpPost request = new HttpPost(url);
            request.addHeader("Authorization", Authentication);

            List<NameValuePair> nvps = new ArrayList<NameValuePair>();
            nvps.add(new BasicNameValuePair("instance_id", "ca08bd52-5049-4f41-bcfe-7140e8052c28"));
            nvps.add(new BasicNameValuePair("device", "/dev/sdi"));
            request.setEntity(new UrlEncodedFormEntity(nvps, HTTP.UTF_8));

            HttpResponse httpResponse = client.execute(request);
            System.out.println("httpResponse.getStatusLine().getStatusCode()---->>>>" + httpResponse.getStatusLine().getStatusCode());
            BufferedReader rd = new BufferedReader(new InputStreamReader(httpResponse.getEntity().getContent()));
            while (rd.readLine() != null) {
                result += rd.readLine();
            }
            System.out.println("\n Result >>> " + result);
        } catch (Exception e) {
            e.printStackTrace();
            result = "Caught in Exception";
        }
        return result;
    }

    /**
     * This method will take url information,authentication,volume_id and calls the deltacloud Gateways with POST method and snapshot the specified volume.
     * @param url
     * @param Authentication
     * @param volume_id
     * @return
     */
    public String snapshotVolume(String url, String Authentication, String volume_id) {
        String result = "";
        try {
            //String url = "http://192.168.1.102:3001/api/storage_snapshots?format=xml";

            System.out.println("\n url >>> " + url);
            System.out.println(" auth >>> " + Authentication);

            HttpClient client = new DefaultHttpClient();
            HttpPost request = new HttpPost(url);
            request.addHeader("Authorization", Authentication);

            List<NameValuePair> nvps = new ArrayList<NameValuePair>();
            nvps.add(new BasicNameValuePair("volume_id", "6"));
            request.setEntity(new UrlEncodedFormEntity(nvps, HTTP.UTF_8));

            HttpResponse httpResponse = client.execute(request);
            System.out.println("httpResponse.getStatusLine().getStatusCode()---->>>>" + httpResponse.getStatusLine().getStatusCode());
            BufferedReader rd = new BufferedReader(new InputStreamReader(httpResponse.getEntity().getContent()));
            while (rd.readLine() != null) {
                result += rd.readLine();
            }
            System.out.println("\n Result >>> " + result);
        } catch (Exception e) {
            e.printStackTrace();
            result = "Caught in Exception";
        }
        return result;
    }

    /**
     * This method will take url information , authentication and calls the deltacloud Gateways with GET method and list the all available instance states.
     * @param url
     * @param Authentication
     * @return
     */
    public String getInstanceStates(String url, String Authentication) {
        String result = "";
        try {
            //String url = "http://192.168.1.102:3001/api/instance_states?format=xml";

            System.out.println("\n url >>> " + url);
            System.out.println(" auth >>> " + Authentication);

            HttpClient client = new DefaultHttpClient();
            HttpGet request = new HttpGet(url);

            request.setHeader("Authorization", Authentication);
            HttpResponse httpResponse = client.execute(request);

            BufferedReader rd = new BufferedReader(new InputStreamReader(httpResponse.getEntity().getContent()));
            while (rd.readLine() != null) {
                result += rd.readLine();
            }

            System.out.println("\n Result >>> " + result);
        } catch (Exception e) {
            e.printStackTrace();
            result = "Caught in Exception";
        }
        return result;
    }


}

Delta Cloud Overview

noreply@blogger.com (Rambros) — Sat, 03 Aug 2013 06:09:00 +0000

As a part of cloud compatability poc , i did a POC on delta cloud.

Delta-cloud is an API was initiated and developed by Red Hat and is now a project hosted at the Apache Software Foundation that abstracts differences between clouds.

The DeltaCloud API provides a single API interface and drivers to work with multiple IaaS (Infrastructure-as-a-Service) cloud computing providers.

Apache Delta-cloud currently supports many back-end cloud providers.

The back-end drivers communicating with each cloud provider's native API and the Delta-cloud Core Framework provides the basis for implementing drivers to new IaaS clouds.

Deltacloud API supports the following providers:

Amazon EC2
GoGrid
OpenNebula
Rackspace
RHEV-M (Red Hat Enterprise Virtualization - Manager)
RimuHosting.

For Overview?

Is an open source Apache project
Is a REST-based API for simple any-platform and any-cloud access.
Is written in Ruby
Comes with client libraries for our favorite programming language

What does Delta-cloud give you?

An opportunity to manage cloud instances the way you want
A way to protect our apps from cloud API changes and incompatibilities
Three front-ends: 'classic' Delta-cloud, DMTF (Distributed Management Task Force) CIMI (Cloud Infrastructure Management Interface), and EC2
support for all major cloud service providers
makes it easy for cloud providers to add their cloud

Reference Link:

http://cloudevangelist.org/tag/deltacloud/

Primefaces Dropdown with Pagination & Filter

noreply@blogger.com (Rambros) — Mon, 15 Jul 2013 14:24:00 +0000

Hi Folks,

I would like to share my another POC task in JSF with you all.

"Primefaces Dropdown with Pagination & Filter "

Dropdown with Filter and Pagination which sounds like component available of the shelves but not really. Prime-faces offers various components which are quite rich in UI and ease of use. They provide variation in Dropdown SelectOneMenu in prime-faces , one such variation is filter inside the dropdown. But they don't support pagination in that. It is also difficult to customize the dropdown by rendering a custom paginator inside it, as the entire drop down UI becomes poor.

I tried a cross combination which will provide expected feature without using Dropdown The main idea of dropdown is collapsible with a list inside, so we tried Accordion Panel which offers collapsible feature and used a data-table inside that which provides paginator along with lazy-data-model. Now i have to provide a filter for searching inside the list, so i have created a text-input component in the column header with Ajax support to update the Data-table with new set of data. So now we have the filter and paginator for the list and since it is in accordion panel , the container is collapsible.

Important Code snippets :

customcomponent.xhtml :

This is a simple jsf page with primefaces Datatable and acoordian panel.

<p:accordionPanel style="width: 275px !important;" >
       <p:tab title="Select the required value" >
            <p:dataTable style="width: 100px!important; height: 200px!important;padding-left: -50px!
important;" lazy="true" id="multiCars" var="fet" value="#{myDropDownBean.lazyModel}"
paginator="true" rows="10" paginatorPosition="bottom"
            selection="#{myDropDownBean.dtc}" selectionMode="single" rowKey="#{fet.nme}"
            paginatorTemplate="{RowsPerPageDropdown} {FirstPageLink} {PreviousPageLink}
{CurrentPageReport} {NextPageLink} {LastPageLink}" >
<p:ajax event="rowSelect" listener="#{myDropDownBean.onRowSelect}">
                        </p:ajax>
                        <p:ajax event="rowUnselect" listener="#{myDropDownBean.onRowUnselect}" />
                        <p:column style="width: 100px!important;" >
                            <f:facet name="header">
                                <p:inputText value="#{myDropDownBean.txtSearch}">
                                    <p:ajax event="keyup" listener="#{myDropDownBean.serachMe}" update="multiCars"/>
                                </p:inputText>
                            </f:facet>
                              #{fet.name}
                        </p:column>
               </p:dataTable>
        </p:tab>
</p:accordionPanel>

The lines below provides the header with input text and will act as a filter with ajax call.

<p:column style="width: 100px!important;" >
                            <f:facet name="header">
                                <p:inputText value="#{myDropDownBean.txtSearch}">
                                    <p:ajax event="keyup" listener="#{myDropDownBean.serachMe}" update="multiCars"/>
                                </p:inputText>
                            </f:facet>
                              #{fet.name}
</p:column>

MyDropDownBean.java :

This is the class which is going to provide the required feature.

The variable to store the filter value provided via TextInput.

private String txtSearch="";

    public String getTxtSearch() {
        return txtSearch;
    }

    public void setTxtSearch(String txtSearch) {
        this.txtSearch = txtSearch;
    }

Action Listner Method that will be called from Ajax event of the textinput,

public void serachMe(){

        System.out.println("this is text box value bean...."+getTxtSearch());
          lazyModel = new LazyDataModel<BeanforCheckbox>() {
                    public List<BeanforCheckbox> load(int first, int pageSize, String sortField, SortOrder
sortOrder, Map<String, String> filters) {
                List<BeanforCheckbox> lazyCars = populateLazyvalueSearch(pageSize, first,getTxtSearch()
);
                return lazyCars;
            }
        };
        lazyModel.setRowCount(cnt);
    }
}

List<BeanforCheckbox> populateLazyvalueSearch(int limit, int offset,String txt) {
        List<BeanforCheckbox> d = null;
    try {
                d = new DbClassCheck().selectRecordsSearch(limit, offset,txt);
                cnt=d.size();
        } catch (Exception e) {
            e.printStackTrace();
    }
        return d;
    }

Full Code :

customcomponent.xhtml

<html xmlns="http://www.w3.org/1999/xhtml"
      xmlns:h="http://java.sun.com/jsf/html" xmlns:p="http://primefaces.org/ui"
      xmlns:f="http://java.sun.com/jsf/core" xmlns:ui="http://java.sun.com/jsf/facelets">
    <h:head>
        <title>Facelet Title</title>
    </h:head>
    <h:body>
        <h:form>
              <p:accordionPanel style="width: 275px !important;" >
                <p:tab title="Select the required value" >
            <p:dataTable style="width: 100px!important; height: 200px!important;padding-left: -50px!important;" lazy="true" id="multiCars" var="fet" value="#{myDropDownBean.lazyModel}" paginator="true" rows="10" paginatorPosition="bottom"
                         selection="#{myDropDownBean.dtc}" selectionMode="single" rowKey="#{fet.name}"
                                 paginatorTemplate="{RowsPerPageDropdown} {FirstPageLink} {PreviousPageLink} {CurrentPageReport} {NextPageLink} {LastPageLink}" >
                        <p:ajax event="rowSelect" listener="#{myDropDownBean.onRowSelect}">

                        </p:ajax>
                        <p:ajax event="rowUnselect" listener="#{myDropDownBean.onRowUnselect}" />

                        <p:column style="width: 100px!important;" >
                            <f:facet name="header">

                                <p:inputText value="#{myDropDownBean.txtSearch}">
                                    <p:ajax event="keyup" listener="#{myDropDownBean.serachMe}" update="multiCars"/>
                                </p:inputText>



                            </f:facet>
                              #{fet.name}
                        </p:column>
                    </p:dataTable>
                      </p:tab>
            </p:accordionPanel>
        </h:form>
    </h:body>
</html>

MyDropDownBean.java :

package beanclass;

import java.io.IOException;
import java.io.Serializable;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.annotation.PostConstruct;
import javax.faces.application.FacesMessage;
import javax.faces.bean.ManagedBean;
import javax.faces.bean.SessionScoped;
import javax.faces.bean.ViewScoped;
import javax.faces.context.FacesContext;
import org.primefaces.event.SelectEvent;
import org.primefaces.event.UnselectEvent;
import org.primefaces.model.*;

@ManagedBean
@ViewScoped
public class MyDropDownBean implements Serializable {

    private String name;
    private BeanforCheckbox dtc;
    private List<columnModel> columns;
    private ArrayList<BeanforCheckbox> multipledtc = new ArrayList<BeanforCheckbox>();
    private String columnName;
    private boolean head = false;
    private MultiBean mb = null;
    public boolean glb = false;
private String txtSearch="";

    public String getTxtSearch() {
        return txtSearch;
    }

    public void setTxtSearch(String txtSearch) {
        this.txtSearch = txtSearch;
    }
    public boolean isHead() {
        if (glb) {
            head = mb.isChk();
        }
        System.out.println("inside ishad---");
        return head;
    }

    public void setHead(boolean head) {
        this.head = head;
    }

    public BeanforCheckbox getDtc() {
        return dtc;
    }
    private LazyDataModel<BeanforCheckbox> lazyModel;

    public void setLazyModel(LazyDataModel<BeanforCheckbox> lazyModel) {
        this.lazyModel = lazyModel;
    }

    public LazyDataModel<BeanforCheckbox> getLazyModel() {

        return lazyModel;
    }

    public void setDtc(BeanforCheckbox dtc) {
        this.dtc = dtc;
    }
    private ArrayList<DataTableClass> alist = new ArrayList<DataTableClass>();

    public ArrayList<DataTableClass> getAlist() {
        return alist;
    }

    public ArrayList<BeanforCheckbox> getMultipledtc() {
        return multipledtc;
    }

    public void setMultipledtc(ArrayList<BeanforCheckbox> multipledtc) {
        this.multipledtc = multipledtc;
    }

    @PostConstruct
    public void onload() {
        mb = new MultiBean();
        alist.add(new DataTableClass("1", "raghu", "jsf", 1));

        System.out.println("---fffff----------" + lazyModel.getRowCount());
        //createDynamicColumns();
    }

    public String getNamenew() {
        return namenew;
    }

    public void setNamenew(String namenew) {
        this.namenew = namenew;
    }
    private String namenew;

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public List<columnModel> getColumns() {
        return columns;
    }

    public String getColumnName() {
        return columnName;
    }

    public void setColumnName(String columnName) {
        this.columnName = columnName;
    }

    public MyDropDownBean(String name) {
        this.name = name;
    }

    public MyDropDownBean() {
try{
        lazyModel = new LazyDataModel<BeanforCheckbox>() {

            /**
             * Dummy implementation of loading a certain segment of data.
             * In a real application, this method should load data from a datasource
             */
            public List<BeanforCheckbox> load(int first, int pageSize, String sortField, SortOrder sortOrder, Map<String, String> filters) {
                // logger.log(Level.INFO, "Loading the lazy car data between {0} and {1}", new Object[]{first, (first+pageSize)});

                //Sorting and Filtering information are not used for demo purposes just random dummy data is returned
                //lazyModel.setRowCount(0);
                List<BeanforCheckbox> lazyCars = populateLazyvalue(pageSize, first);
                System.out.println("lazyCars-----" + lazyCars.size());
                return lazyCars;
            }
        };
        lazyModel.setRowCount(new DbClassCheck().getRecordCount());
}
catch(Exception er){
    er.printStackTrace();
}
    }

    public void onRowSelect(SelectEvent event) {
        try {

        } catch (Exception ex) {
            ex.printStackTrace();
        }
    }

    public void onRowUnselect(UnselectEvent event) {
        try {
            //   FacesContext.getCurrentInstance().getExternalContext().redirect("index.xhtml");
        } catch (Exception ex) {
            ex.printStackTrace();
        }
    }

    public void view(BeanforCheckbox d) {

        System.out.println("d--view-->" + d.isCheck());

        boolean flag = false;
        if ((d.isCheck() == false) && (mb.isChk())) {
            multipledtc = new ArrayList<BeanforCheckbox>();
            mb.setChk(false);

            lazyModel = new LazyDataModel<BeanforCheckbox>() {


            public List<BeanforCheckbox> load(int first, int pageSize, String sortField, SortOrder sortOrder, Map<String, String> filters) {

                List<BeanforCheckbox> lazyCars = populateLazyvalue(pageSize, first);
                System.out.println("lazyCars-----" + lazyCars.size());
                return lazyCars;
            }
           @Override
            public void setRowIndex(int rowIndex) {

               System.out.println("row index..............");
                if (rowIndex == -1 || getPageSize() == 0) {
                    super.setRowIndex(-1);
                } else {
                    super.setRowIndex(rowIndex % getPageSize());
                }
            }
            @Override
            public BeanforCheckbox getRowData(String url) {
                for (BeanforCheckbox list : lazyModel) {
                    if (url.equals(list.getName())) {
                        return list;
                    }
                }
                return null;
            }
        };
        lazyModel.setRowCount(30);

        }

        if (multipledtc.size() > 0) {
            for (int i = 0; i < multipledtc.size(); i++) {
                BeanforCheckbox d1 = multipledtc.get(i);
                if (d.getName().equalsIgnoreCase(d1.getName())) {
                    flag = false;
                    if (d1.isCheck() == false) {
                        multipledtc.remove(i);
                    }
                    break;
                } else {
                    flag = true;
                }
            }
        } else {
            flag = false;
            if (d.isCheck()) {
                multipledtc.add(d);
            }
        }
        if (flag) {
            multipledtc.add(d);
        }

    }

    public void redirectInput() {
        try {
            FacesContext.getCurrentInstance().getExternalContext().redirect("inputdisplay.xhtml");
        } catch (IOException ex) {
            ex.printStackTrace();
        }
    }

    List<BeanforCheckbox> populateLazyvalue(int limit, int offset) {
        System.out.println("inside populate--->" + limit + "--offset---->" + offset);

        List<BeanforCheckbox> d = null;
        try {
            cnt=new DbClassCheck().getRecordCount();
            System.out.println("cnt value----->"+cnt);
            d = new DbClassCheck().selectRecords(limit, offset);
            for (int i = 0; i < d.size(); i++) {
                BeanforCheckbox bc = d.get(i);
                for (int j = 0; j < multipledtc.size(); j++) {
                    System.out.println("inside j loop");
                    BeanforCheckbox bc1 = multipledtc.get(j);
                    if (bc1.getName().equalsIgnoreCase(bc.getName())) {
                        System.out.println("inside j's if-----" + bc1.isCheck());
                        d.remove(i);
                        d.add(i, bc1);
                    }
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }

        return d;
    }

    public void selectAll() {

        System.out.println("inside select all updated........");
        boolean bl = true;
        if (mb.isChk()) {
            mb.setChk(false);
        } else if (mb.isChk() == false) {
            mb.setChk(true);
        }
        mb.setChk(isHead());
        glb = true;
        lazyModel = new LazyDataModel<BeanforCheckbox>() {

            /**
             * Dummy implementation of loading a certain segment of data.
             * In a real application, this method should load data from a datasource
             */
            public List<BeanforCheckbox> load(int first, int pageSize, String sortField, SortOrder sortOrder, Map<String, String> filters) {
                // logger.log(Level.INFO, "Loading the lazy car data between {0} and {1}", new Object[]{first, (first+pageSize)});

                //Sorting and Filtering information are not used for demo purposes just random dummy data is returned
                //lazyModel.setRowCount(0);
                List<BeanforCheckbox> lazyCars = populateLazyvaluecheck(pageSize, first);
                // System.out.println("lazyCars-----" + lazyCars.size());
                return lazyCars;
            }
        };

        lazyModel.setRowCount(cnt);

    }

    List<BeanforCheckbox> populateLazyvaluecheck(int limit, int offset) {
        System.out.println("inside populateLazyvaluecheck--->" + limit + "--offset---->" + offset);
        System.out.println("flg value updated----->" + isHead());
        List<BeanforCheckbox> d = null;
        try {
            if (isHead()) {
                d = new DbClassCheck().selectRecordstrue(limit, offset);
                multipledtc = (ArrayList<BeanforCheckbox>) d;
            } else {
                d = new DbClassCheck().selectRecords(limit, offset);
                multipledtc = (ArrayList<BeanforCheckbox>) d;
            }
cnt=d.size();
        } catch (Exception e) {
            e.printStackTrace();
        }
        return d;
    }
int cnt=0;
    List<BeanforCheckbox> populateLazyvalueSearch(int limit, int offset,String txt) {
        System.out.println("inside populateLazyvaluecheck--->" + limit + "--offset---->" + offset);
        System.out.println("flg value updated----->" + isHead());
        List<BeanforCheckbox> d = null;
        try {

                d = new DbClassCheck().selectRecordsSearch(limit, offset,txt);

                cnt=d.size();

        } catch (Exception e) {
            e.printStackTrace();
        }
        return d;
    }

    public void serachMe(){
        System.out.println("this is text box value bean...."+getTxtSearch());
          lazyModel = new LazyDataModel<BeanforCheckbox>() {

            /**
             * Dummy implementation of loading a certain segment of data.
             * In a real application, this method should load data from a datasource
             */
            public List<BeanforCheckbox> load(int first, int pageSize, String sortField, SortOrder sortOrder, Map<String, String> filters) {
                // logger.log(Level.INFO, "Loading the lazy car data between {0} and {1}", new Object[]{first, (first+pageSize)});

                //Sorting and Filtering information are not used for demo purposes just random dummy data is returned
                //lazyModel.setRowCount(0);
                List<BeanforCheckbox> lazyCars = populateLazyvalueSearch(pageSize, first,getTxtSearch());
                // System.out.println("lazyCars-----" + lazyCars.size());
                return lazyCars;
            }
        };

        lazyModel.setRowCount(cnt);
    }
}

DbClassCheck.java :

package beanclass;

import java.sql.*;
import java.util.ArrayList;
import java.util.List;
public class DbClassCheck {

    List<BeanforCheckbox> selectRecords(int lim,int off) throws SQLException{
        Connection con=null;
         Statement st = null;
         ResultSet rs=null;
         List<BeanforCheckbox> d=null;
        try{
         Class.forName("com.mysql.jdbc.Driver");
            con = DriverManager.getConnection("jdbc:mysql://localhost:3306/testing?zeroDateTimeBehavior=convertToNull", "root", "root");
            st=con.createStatement();
            rs=st.executeQuery("select name,description,status,id from testnew limit "+lim+" offset "+off);
            d = new ArrayList<BeanforCheckbox>();
             while (rs.next()) {
            //    System.out.println("dddd");
                d.add(new BeanforCheckbox(rs.getString(1), rs.getString(2), rs.getString(3), rs.getInt(4),false));
            }
        }
        catch(Exception e){
            e.printStackTrace();
        }
         finally{
             if(con!=null){
                 con.close();
             }
         }
         return d;
    }
    List<BeanforCheckbox> selectRecordstrue(int lim,int off) throws SQLException{
        Connection con=null;
         Statement st = null;
         ResultSet rs=null;
         List<BeanforCheckbox> d=null;
        try{
         Class.forName("com.mysql.jdbc.Driver");
            con = DriverManager.getConnection("jdbc:mysql://localhost:3306/testing?zeroDateTimeBehavior=convertToNull", "root", "root");
            st=con.createStatement();
            rs=st.executeQuery("select name,description,status,id from testnew limit "+lim+" offset "+off);
            d = new ArrayList<BeanforCheckbox>();
             while (rs.next()) {
             //   System.out.println("dddd");
                d.add(new BeanforCheckbox(rs.getString(1), rs.getString(2), rs.getString(3), rs.getInt(4),true));
            }
        }
        catch(Exception e){
            e.printStackTrace();
        }
         finally{
             if(con!=null){
                 con.close();
             }
         }
         return d;
    }
     List<BeanforCheckbox> selectRecordsSearch(int lim,int off,String nam) throws SQLException{
        Connection con=null;
         Statement st = null;
         ResultSet rs=null;
         List<BeanforCheckbox> d=null;
        try{
         Class.forName("com.mysql.jdbc.Driver");
            con = DriverManager.getConnection("jdbc:mysql://localhost:3306/testing?zeroDateTimeBehavior=convertToNull", "root", "root");
            st=con.createStatement();
            rs=st.executeQuery("select name,description,status,id from testnew where name like '%"+nam+"%'limit "+lim+" offset "+off);
            d = new ArrayList<BeanforCheckbox>();
             while (rs.next()) {
             //   System.out.println("dddd");
                d.add(new BeanforCheckbox(rs.getString(1), rs.getString(2), rs.getString(3), rs.getInt(4),true));
            }
        }
        catch(Exception e){
            e.printStackTrace();
        }
         finally{
             if(con!=null){
                 con.close();
             }
         }
         return d;
    }
     int getRecordCount() throws SQLException{
          Connection con=null;
         Statement st = null;
         ResultSet rs=null;
         int d=0;
        try{
         Class.forName("com.mysql.jdbc.Driver");
            con = DriverManager.getConnection("jdbc:mysql://localhost:3306/testing?zeroDateTimeBehavior=convertToNull", "root", "root");
            st=con.createStatement();
            rs=st.executeQuery("select count(*) from testnew");

             if (rs.next()) {
             //   System.out.println("dddd");
                d=rs.getInt(1);
            }
        }
        catch(Exception e){
            e.printStackTrace();
        }
         finally{
             if(con!=null){
                 con.close();
             }
         }
         return d;
     }

}

BeanforCheckbox.java :

package beanclass;

import java.io.Serializable;

public class BeanforCheckbox implements Serializable {

    private String name;
    private String roll;
    private String gender;
    private int id;
    private boolean check = false;

    public int getId() {
        return id;
    }

    public boolean isCheck() {
        return check;
    }

    public void setCheck(boolean check) {
        this.check = check;
    }

    public void setId(int id) {
        this.id = id;
    }

    public BeanforCheckbox(String name, String roll, String gender, int id, boolean check) {
        this.name = name;
        this.roll = roll;
        this.gender = gender;
        this.id = id;
        this.check = check;
    }

    public String getGender() {
        return gender;
    }

    public void setGender(String gender) {
        this.gender = gender;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getRoll() {
        return roll;
    }

    public void setRoll(String roll) {
        this.roll = roll;
    }
}

Try it and let me know. This is not robust as it just a POC.

Primefaces Datatable with header Check-box Selection

noreply@blogger.com (Rambros) — Wed, 10 Jul 2013 11:15:00 +0000

Hi folks,

I got a chance to work with JSF, it was an interesting requirement. Its about a custom component which would be of more use to our product.

Component Description :
The display of the component (Datatable) will be row wise check-box and top header check-box. Functionality will be by clicking each individual row check-box should select or unselect the row. By clicking the top header Check-box should select or unselect all the rows within the page.

Prime Faces Datatable offers a wide verity of features.

PROS of Prime Faces MultiSelection:

PrimeFaces offers the Multiselection feature with ease.

CONS of Prime Faces MultiSelection:

MultiSelection Feature with LazyDataModel works well within the page of DataTable.

Work Around :

Implement the single selection with LazyDataModel in DataTable and customize to make it work of Multi Selection feature with PrimeFace-Ajax script and a ArrayList.

Code Snippets :

DbClassCheck.Java :

This class is a simple db interaction class, here we are creating db connection and fetching records from a table with limit and offset. It should self Explanatory.

MultiBean.Java :

This Class is just a sample class which i used to store header checkbox value. In the provided source code you will find irrelevant snippets because i needed some class so made use of one of my existing class.

Important Snippets :

   private boolean chk=false;

    public boolean isChk() {
        return chk;
    }

    public void setChk(boolean chk) {
        this.chk = chk;
    }

Full class :-

package beanclass;
import java.io.IOException;
import java.io.Serializable;
import java.util.ArrayList;
import java.util.List;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.annotation.PostConstruct;
import javax.faces.application.FacesMessage;
import javax.faces.bean.ManagedBean;
import javax.faces.bean.SessionScoped;
import javax.faces.context.FacesContext;
import org.primefaces.event.SelectEvent;
import org.primefaces.event.UnselectEvent;
import org.primefaces.model.*;
@ManagedBean
@SessionScoped
public class MultiBean implements Serializable {

    private String name;
    private DataTableClass[] dtc;
    private List<columnModel> columns;
private boolean chk=false;

    public boolean isChk() {
        return chk;
    }

    public void setChk(boolean chk) {
        this.chk = chk;
    }
    public SelectionModel getSmodel() {
        return smodel;
    }
    private String columnName;
    private SelectionModel smodel;

    public DataTableClass[] getDtc() {
        return dtc;
    }

    public void setDtc(DataTableClass[] dtc) {
        this.dtc = dtc;
    }
    private ArrayList<DataTableClass> alist = new ArrayList<DataTableClass>();

    public ArrayList<DataTableClass> getAlist() {
        return alist;
    }

    @PostConstruct
    public void onload() {
        alist.add(new DataTableClass("1", "raghu", "jsf", 1));
        alist.add(new DataTableClass("2", "gopal", "jsf", 2));
        alist.add(new DataTableClass("3", "noorul", "flex", 3));
        alist.add(new DataTableClass("4", "raja", "html", 4));
        alist.add(new DataTableClass("5", "udhay", "html", 5));
         alist.add(new DataTableClass("11", "raghu1", "jsf1", 11));
        alist.add(new DataTableClass("12", "gopal1", "jsf1", 12));
        alist.add(new DataTableClass("13", "noorul1", "flex1", 13));
        alist.add(new DataTableClass("14", "raja1", "html1", 14));
        alist.add(new DataTableClass("15", "udhay1", "html1", 15));
         alist.add(new DataTableClass("21", "raghu2", "jsf2", 21));
        alist.add(new DataTableClass("22", "gopal2", "jsf2", 22));
        alist.add(new DataTableClass("23", "noorul2", "flex2", 23));
        alist.add(new DataTableClass("24", "raja2", "html2", 24));
        alist.add(new DataTableClass("25", "udhay2", "html2", 25));
         alist.add(new DataTableClass("31", "raghu3", "jsf", 31));
        alist.add(new DataTableClass("32", "gopal3", "jsf", 32));
        alist.add(new DataTableClass("33", "noorul3", "flex", 33));
        alist.add(new DataTableClass("34", "raja3", "html", 34));
        alist.add(new DataTableClass("35", "udhay3", "html", 35));
         alist.add(new DataTableClass("41", "raghu4", "jsf4", 41));
        alist.add(new DataTableClass("42", "gopal4", "jsf4", 42));
        alist.add(new DataTableClass("43", "noorul4", "flex4", 43));
        alist.add(new DataTableClass("44", "raja4", "html4", 44));
        alist.add(new DataTableClass("45", "udhay4", "html4", 45));
        smodel = new SelectionModel(alist);
        //createDynamicColumns();
    }

    public String getNamenew() {
        return namenew;
    }

    public void setNamenew(String namenew) {
        this.namenew = namenew;
    }
    private String namenew;

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public List<columnModel> getColumns() {
        return columns;
    }

    public String getColumnName() {
        return columnName;
    }

    public void setColumnName(String columnName) {
        this.columnName = columnName;
    }

    public MultiBean(String name) {
        this.name = name;
    }

    public MultiBean() {
    }

    public void sayHello(String s) {
        System.out.println("added parameter.......>>>>> " + s + getName());

    }

    public void sayHelloNew() {
        System.out.println("say Hello world New......" + getNamenew());

    }

    public void onRowSelect(SelectEvent event) {
        try {
            // setDtc(((DataTableClass) event.getObject()));
            //   DataTableClass d = getDtc();
            //   System.out.println("d---->" + d.getName());
            FacesContext.getCurrentInstance().getExternalContext().redirect("faces/page1.xhtml");
        } catch (IOException ex) {
            ex.printStackTrace();
        }
    }

    public void onRowUnselect(UnselectEvent event) {
        try {
            FacesContext.getCurrentInstance().getExternalContext().redirect("index.xhtml");

        } catch (IOException ex) {
            ex.printStackTrace();
        }
    }

    private void createDynamicColumns() {

        columns = new ArrayList<columnModel>();
        columns.add(new columnModel("Name", "name"));
        columns.add(new columnModel("Role", "roll"));
        columns.add(new columnModel("Gender", "gender"));
        columns.add(new columnModel("ID", "id"));
    }

    public void redirectInput() {
        try {
            FacesContext.getCurrentInstance().getExternalContext().redirect("inputdisplay.xhtml");
        } catch (IOException ex) {
            ex.printStackTrace();
        }
    }
}

BeanforCheckbox.java:

This is again self explanatory bean class, we are using this class as our Data class to populate the Datatable.

package beanclass;
import java.io.Serializable;
public class BeanforCheckbox implements Serializable {

    private String name;
    private String roll;
    private String gender;
    private int id;
    private boolean check = false;

    public int getId() {
        return id;
    }

    public boolean isCheck() {
        return check;
    }

    public void setCheck(boolean check) {
        this.check = check;
    }

    public void setId(int id) {
        this.id = id;
    }

    public BeanforCheckbox(String name, String roll, String gender, int id, boolean check) {
        this.name = name;
        this.roll = roll;
        this.gender = gender;
        this.id = id;
        this.check = check;
    }

    public String getGender() {
        return gender;
    }

    public void setGender(String gender) {
        this.gender = gender;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getRoll() {
        return roll;
    }

    public void setRoll(String roll) {
        this.roll = roll;
    }
}

CustomCheckBox.xhtml:

This is a simple jsf page with primefaces Datatable.

Important Snippets:

<p:dataTable lazy="true" id="multiCars" var="fet" value="#{myCheckboxBean.lazyModel}" paginator="true" rows="10"
                                 selection="#{myCheckboxBean.dtc}" selectionMode="single" rowKey="#{fet.name}" rowsPerPageTemplate="10,20,25"
                                 paginatorTemplate="{RowsPerPageDropdown} {FirstPageLink} {PreviousPageLink} {CurrentPageReport}
                                {NextPageLink} {LastPageLink}" >
                        <p:ajax event="rowSelect" listener="#{myCheckboxBean.onRowSelect}">

                        </p:ajax>
                        <p:ajax event="rowUnselect" listener="#{myCheckboxBean.onRowUnselect}" />

                        <p:column headerText="Name" >
                            #{fet.name}
                        </p:column>

                        <p:column headerText="Roll" >
                            #{fet.roll}
                        </p:column>

                        <p:column headerText="Gender">
                            #{fet.gender}
                        </p:column>

                        <p:column >
                            <f:facet name="header">
                                <h:selectBooleanCheckbox id="all_transactionIdChkb" value="#{myCheckboxBean.head}" >
                                    <p:ajax update="multiCars" event="click" listener="#{myCheckboxBean.selectAll}"/>
                                </h:selectBooleanCheckbox>
                            </f:facet>
                            <p:selectBooleanCheckbox value="#{fet.check}">
                                <p:ajax update="multiCars" listener="#{myCheckboxBean.view(fet)}"/>
                            </p:selectBooleanCheckbox>
                        </p:column>

     </p:dataTable>

The Datatable property lazy="true" sets the lazy data model operative by populating the "myCheckboxBean.lazyModel" . Propery selectionMode="single" enables the Datattable row selecting option.

Below lines are required to enable row selection along with the SelectionMode property. Our Row-Wise checkbox works because of this.

<p:ajax event="rowSelect" listener="#{myCheckboxBean.onRowSelect}" />
<p:ajax event="rowUnselect" listener="#{myCheckboxBean.onRowUnselect}" />

Below lines sets the checkbox at the header and provides select all feature.

                            <f:facet name="header">
                                <h:selectBooleanCheckbox id="all_transactionIdChkb" value="#{myCheckboxBean.head}" >
                                    <p:ajax update="multiCars" event="click" listener="#{myCheckboxBean.selectAll}"/>
                                </h:selectBooleanCheckbox>
                            </f:facet>
Below lines sets the row-wise checkbox ,

<p:selectBooleanCheckbox value="#{fet.check}">
                                <p:ajax update="multiCars" listener="#{myCheckboxBean.view(fet)}"/>
                            </p:selectBooleanCheckbox>

Full Code :

<?xml version='1.0' encoding='UTF-8' ?>
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">
<html xmlns="http://www.w3.org/1999/xhtml"
      xmlns:h="http://java.sun.com/jsf/html" xmlns:p="http://primefaces.org/ui"
      xmlns:f="http://java.sun.com/jsf/core" xmlns:ui="http://java.sun.com/jsf/facelets">
    <h:head>
        <title>Custom Header Selection</title>
    </h:head>
    <h:body>
        <ui:composition template="/commonLayout.xhtml">
            <ui:define name="content">

                <br></br><br></br>

                <h:form id="form">
                    <p:dataTable lazy="true" id="multiCars" var="fet" value="#{myCheckboxBean.lazyModel}" paginator="true" rows="10"
                                 selection="#{myCheckboxBean.dtc}" selectionMode="single" rowKey="#{fet.name}" rowsPerPageTemplate="10,20,25"
                                 paginatorTemplate="{RowsPerPageDropdown} {FirstPageLink} {PreviousPageLink} {CurrentPageReport} {NextPageLink} {LastPageLink}" >
                        <p:ajax event="rowSelect" listener="#{myCheckboxBean.onRowSelect}">

                        </p:ajax>
                        <p:ajax event="rowUnselect" listener="#{myCheckboxBean.onRowUnselect}" />
                        <f:facet name="header">
                            Checkbox Based Selection
                        </f:facet>

                        <p:column headerText="Name" >

                            #{fet.name}

                        </p:column>
                        <p:column headerText="Roll" >

                            #{fet.roll}

                        </p:column>
                        <p:column headerText="Gender">
                            #{fet.gender}

                        </p:column>

                        <f:facet name="footer">
                            <p:commandButton id="multiViewButton" value="View" icon="ui-icon-search"
                                             update=":form:displayMulti" oncomplete="multiCarDialog.show()"/>
                        </f:facet>
                        <p:column >
                            <f:facet name="header">
                                <h:selectBooleanCheckbox id="all_transactionIdChkb" value="#{myCheckboxBean.head}" >
                                    <p:ajax update="multiCars" event="click" listener="#{myCheckboxBean.selectAll}"/>
                                </h:selectBooleanCheckbox>
                            </f:facet>

                            <p:selectBooleanCheckbox value="#{fet.check}">
                                <p:ajax update="multiCars" listener="#{myCheckboxBean.view(fet)}"/>
                            </p:selectBooleanCheckbox>

                        </p:column>
                    </p:dataTable>
                    <p:dialog id="multiDialog" header="Detail" widgetVar="multiCarDialog"
                              height="300" showEffect="fade" hideEffect="explode">

                        <p:dataList id="displayMulti"
                                    value="#{myCheckboxBean.multipledtc}" var="fet">
                            Name #{fet.name}, Roll #{fet.roll}
                        </p:dataList>

                    </p:dialog>
                </h:form>

            </ui:define>
        </ui:composition>
    </h:body>
</html>

MyCheckboxBean.java :
This is the class which is going to provide the required feature.

Important Snippets :

private ArrayList<BeanforCheckbox> multipledtc = new ArrayList<BeanforCheckbox>();

The variable multipledtc is arraylist which is going to store the selected values in the Datatable.

    private boolean head = false;
    private MultiBean mb = null;
    public boolean glb = false;

Variable head,mb,glb are required to maintain the Header Selection and pass on the value to row-wise checkbox.

The getter and setter of head variable, is must one to watch over. When the Datatable page is navigated the head variable becomes false even if we set it to checked status in the previous page. It means the PrimeFaces renders the headers as well while Page-navigation. SO we mocked the getter of head variable. While selecting the header checkbox we will call selectAll method, there we will set the value for glb and mb variable. In the same select all method based on the head value we will the reload datatable by populating re-lazydatamodel.

public boolean isHead() {
        if (glb) {
            head = mb.isChk();
        }
        System.out.println("inside ishad---");
        return head;
    }

    public void setHead(boolean head) {
        this.head = head;
    }

public void selectAll() {

        System.out.println("inside select all updated........");
        boolean bl = true;
        if (mb.isChk()) {
            mb.setChk(false);
        } else if (mb.isChk() == false) {
            mb.setChk(true);
        }
        mb.setChk(isHead());
        glb = true;
        lazyModel = new LazyDataModel<BeanforCheckbox>() {

            public List<BeanforCheckbox> load(int first, int pageSize, String sortField, SortOrder sortOrder, Map<String, String> filters) {

                List<BeanforCheckbox> lazyCars = populateLazyvaluecheck(pageSize, first);

                return lazyCars;
            }
        };

        lazyModel.setRowCount(30);

    }

List<BeanforCheckbox> populateLazyvaluecheck(int limit, int offset) {
        System.out.println("inside populateLazyvaluecheck--->" + limit + "--offset---->" + offset);
        System.out.println("flg value updated----->" + isHead());
        List<BeanforCheckbox> d = null;
        try {
            if (isHead()) {
                d = new DbClassCheck().selectRecordstrue(limit, offset);
                multipledtc = (ArrayList<BeanforCheckbox>) d;
            } else {
                d = new DbClassCheck().selectRecords(limit, offset);
                multipledtc = (ArrayList<BeanforCheckbox>) d;
            }

        } catch (Exception e) {
            e.printStackTrace();
        }
        return d;
    }

Below lines are from view method , those lines updates the value of multipledtc variable.

    if (multipledtc.size() > 0) {
            for (int i = 0; i < multipledtc.size(); i++) {
                BeanforCheckbox d1 = multipledtc.get(i);
                if (d.getName().equalsIgnoreCase(d1.getName())) {
                    flag = false;
                    if (d1.isCheck() == false) {
                        multipledtc.remove(i);
                    }
                    break;
                } else {
                    flag = true;
                }
            }
        } else {
            flag = false;
            if (d.isCheck()) {
                multipledtc.add(d);
            }
        }
        if (flag) {
            multipledtc.add(d);
        }

Full Code :

package beanclass;
import java.io.IOException;
import java.io.Serializable;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.annotation.PostConstruct;
import javax.faces.application.FacesMessage;
import javax.faces.bean.ManagedBean;
import javax.faces.bean.SessionScoped;
import javax.faces.bean.ViewScoped;
import javax.faces.context.FacesContext;
import org.primefaces.event.SelectEvent;
import org.primefaces.event.UnselectEvent;
import org.primefaces.model.*;

@ManagedBean
@ViewScoped
public class MyCheckboxBean implements Serializable {

    private String name;
    private BeanforCheckbox dtc;
    private List<columnModel> columns;
    private ArrayList<BeanforCheckbox> multipledtc = new ArrayList<BeanforCheckbox>();
    private String columnName;
    private boolean head = false;
    private MultiBean mb = null;
    public boolean glb = false;

    public boolean isHead() {
        if (glb) {
            head = mb.isChk();
        }
        System.out.println("inside ishad---");
        return head;
    }

    public void setHead(boolean head) {
        this.head = head;
    }

    public BeanforCheckbox getDtc() {
        return dtc;
    }
    private LazyDataModel<BeanforCheckbox> lazyModel;

    public void setLazyModel(LazyDataModel<BeanforCheckbox> lazyModel) {
        this.lazyModel = lazyModel;
    }

    public LazyDataModel<BeanforCheckbox> getLazyModel() {

        return lazyModel;
    }

    public void setDtc(BeanforCheckbox dtc) {
        this.dtc = dtc;
    }
    private ArrayList<DataTableClass> alist = new ArrayList<DataTableClass>();

    public ArrayList<DataTableClass> getAlist() {
        return alist;
    }

    public ArrayList<BeanforCheckbox> getMultipledtc() {
        return multipledtc;
    }

    public void setMultipledtc(ArrayList<BeanforCheckbox> multipledtc) {
        this.multipledtc = multipledtc;
    }

    @PostConstruct
    public void onload() {
        mb = new MultiBean();
        alist.add(new DataTableClass("1", "raghu", "jsf", 1));

    }

    public String getNamenew() {
        return namenew;
    }

    public void setNamenew(String namenew) {
        this.namenew = namenew;
    }
    private String namenew;

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public List<columnModel> getColumns() {
        return columns;
    }

    public String getColumnName() {
        return columnName;
    }

    public void setColumnName(String columnName) {
        this.columnName = columnName;
    }

    public MyCheckboxBean(String name) {
        this.name = name;
    }

    public MyCheckboxBean() {

        lazyModel = new LazyDataModel<BeanforCheckbox>() {

            /**
             * Dummy implementation of loading a certain segment of data.
             * In a real application, this method should load data from a datasource
             */
            public List<BeanforCheckbox> load(int first, int pageSize, String sortField, SortOrder sortOrder, Map<String, String> filters) {
                // logger.log(Level.INFO, "Loading the lazy car data between {0} and {1}", new Object[]{first, (first+pageSize)});

                //Sorting and Filtering information are not used for demo purposes just random dummy data is returned
                //lazyModel.setRowCount(0);
                List<BeanforCheckbox> lazyCars = populateLazyvalue(pageSize, first);
                System.out.println("lazyCars-----" + lazyCars.size());
                return lazyCars;
            }
        };
        lazyModel.setRowCount(30);
    }

    public void onRowSelect(SelectEvent event) {
        try {
            // setDtc(((DataTableClass) event.getObject()));
            //   DataTableClass d = getDtc();
            //   System.out.println("d---->" + d.getName());
            //   FacesContext.getCurrentInstance().getExternalContext().redirect("faces/page1.xhtml");
        } catch (Exception ex) {
            ex.printStackTrace();
        }
    }

    public void onRowUnselect(UnselectEvent event) {
        try {
            //   FacesContext.getCurrentInstance().getExternalContext().redirect("index.xhtml");
        } catch (Exception ex) {
            ex.printStackTrace();
        }
    }

    public void view(BeanforCheckbox d) {
        // FormBean d = getDtc();
        System.out.println("d--view-->" + d.isCheck());
//        setName(d.getName());
//        setGender(d.getGender());
//        setId(d.getId());
//        setRoll(d.getRoll());
        boolean flag = false;
        if ((d.isCheck() == false) && (mb.isChk())) {
            multipledtc = new ArrayList<BeanforCheckbox>();
            mb.setChk(false);

            lazyModel = new LazyDataModel<BeanforCheckbox>() {

            /**
             * Dummy implementation of loading a certain segment of data.
             * In a real application, this method should load data from a datasource
             */
            public List<BeanforCheckbox> load(int first, int pageSize, String sortField, SortOrder sortOrder, Map<String, String> filters) {
                // logger.log(Level.INFO, "Loading the lazy car data between {0} and {1}", new Object[]{first, (first+pageSize)});

                //Sorting and Filtering information are not used for demo purposes just random dummy data is returned
                //lazyModel.setRowCount(0);
                List<BeanforCheckbox> lazyCars = populateLazyvalue(pageSize, first);
                System.out.println("lazyCars-----" + lazyCars.size());
                return lazyCars;
            }
           @Override
            public void setRowIndex(int rowIndex) {
                /*
                 * The following is in ancestor (LazyDataModel): this.rowIndex =
                 * rowIndex == -1 ? rowIndex : (rowIndex % pageSize);
                 */
               System.out.println("row index..............");
                if (rowIndex == -1 || getPageSize() == 0) {
                    super.setRowIndex(-1);
                } else {
                    super.setRowIndex(rowIndex % getPageSize());
                }
            }
            @Override
            public BeanforCheckbox getRowData(String url) {
                for (BeanforCheckbox list : lazyModel) {
                    if (url.equals(list.getName())) {
                        return list;
                    }
                }
                return null;
            }
        };
        lazyModel.setRowCount(30);

        }

        if (multipledtc.size() > 0) {
            for (int i = 0; i < multipledtc.size(); i++) {
                BeanforCheckbox d1 = multipledtc.get(i);
                if (d.getName().equalsIgnoreCase(d1.getName())) {
                    flag = false;
                    if (d1.isCheck() == false) {
                        multipledtc.remove(i);
                    }
                    break;
                } else {
                    flag = true;
                }
            }
        } else {
            flag = false;
            if (d.isCheck()) {
                multipledtc.add(d);
            }
        }
        if (flag) {
            multipledtc.add(d);
        }

    }

    private void createDynamicColumns() {

        columns = new ArrayList<columnModel>();
        columns.add(new columnModel("Name", "name"));
        columns.add(new columnModel("Role", "roll"));
        columns.add(new columnModel("Gender", "gender"));
        columns.add(new columnModel("ID", "id"));
    }

    public void redirectInput() {
        try {
            FacesContext.getCurrentInstance().getExternalContext().redirect("inputdisplay.xhtml");
        } catch (IOException ex) {
            ex.printStackTrace();
        }
    }

    List<BeanforCheckbox> populateLazyvalue(int limit, int offset) {
        System.out.println("inside populate--->" + limit + "--offset---->" + offset);

        List<BeanforCheckbox> d = null;
        try {
            d = new DbClassCheck().selectRecords(limit, offset);
            for (int i = 0; i < d.size(); i++) {
                BeanforCheckbox bc = d.get(i);
                for (int j = 0; j < multipledtc.size(); j++) {
                    System.out.println("inside j loop");
                    BeanforCheckbox bc1 = multipledtc.get(j);
                    if (bc1.getName().equalsIgnoreCase(bc.getName())) {
                        System.out.println("inside j's if-----" + bc1.isCheck());
                        d.remove(i);
                        d.add(i, bc1);
                    }
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        return d;
    }

    public void selectAll() {

        System.out.println("inside select all updated........");
        boolean bl = true;
        if (mb.isChk()) {
            mb.setChk(false);
        } else if (mb.isChk() == false) {
            mb.setChk(true);
        }
        mb.setChk(isHead());
        glb = true;
        lazyModel = new LazyDataModel<BeanforCheckbox>() {

            /**
             * Dummy implementation of loading a certain segment of data.
             * In a real application, this method should load data from a datasource
             */
            public List<BeanforCheckbox> load(int first, int pageSize, String sortField, SortOrder sortOrder, Map<String, String> filters) {
                // logger.log(Level.INFO, "Loading the lazy car data between {0} and {1}", new Object[]{first, (first+pageSize)});

                //Sorting and Filtering information are not used for demo purposes just random dummy data is returned
                //lazyModel.setRowCount(0);
                List<BeanforCheckbox> lazyCars = populateLazyvaluecheck(pageSize, first);
                // System.out.println("lazyCars-----" + lazyCars.size());
                return lazyCars;
            }
        };

        lazyModel.setRowCount(30);

    }

    List<BeanforCheckbox> populateLazyvaluecheck(int limit, int offset) {
        System.out.println("inside populateLazyvaluecheck--->" + limit + "--offset---->" + offset);
        System.out.println("flg value updated----->" + isHead());
        List<BeanforCheckbox> d = null;
        try {
            if (isHead()) {
                d = new DbClassCheck().selectRecordstrue(limit, offset);
                multipledtc = (ArrayList<BeanforCheckbox>) d;
            } else {
                d = new DbClassCheck().selectRecords(limit, offset);
                multipledtc = (ArrayList<BeanforCheckbox>) d;
            }

        } catch (Exception e) {
            e.printStackTrace();
        }
        return d;
    }
}

Try it and let me know.... Have a great day guys...

Custom JDBC Driver

noreply@blogger.com (Rambros) — Tue, 09 Jul 2013 12:46:00 +0000

Hi folks,

I was working for creating a jdbc driver for supporting some db's like mysql,oracle along with connection pooling. So thought just sharing how simple a driver creation is in JAVA. The sample is about writing a wrapper around mysql connector library, once we have this we shall have control over the db operations, like changing the db dynamically based some url's etc.

Following are code snippet ,

Driver :

package com.raghu.jdbc;
import com.raghu.jdbc.nativeconnection.NativeConnection;
import java.sql.Connection;
import java.sql.Driver;
import java.sql.DriverManager;
import java.sql.DriverPropertyInfo;
import java.sql.SQLException;
import java.util.Properties;
public class GenericDriver implements Driver {

    public static GenericDriver driver = null;

    static {
        try {
            driver = new GenericDriver();
            DriverManager.registerDriver(driver);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public Connection connect(String url, Properties info) throws SQLException {
        try {


            if (!acceptsURL(url)) {

                return null;
            }

            System.out.println("############# connect ################");
            System.out.println("############## Properties :" + info);

            url = "jdbc:mysql://localhost:3306/";

            GenericConnection cw=new GenericConnection(new NativeConnection().getNativeConnection(url,"root", "root"));

            return cw;

        } catch (Exception ex) {
            ex.printStackTrace();

        }
        return null;
    }

    public boolean acceptsURL(String url) throws SQLException {
        if ((url != null) && (url.startsWith("common:JDBC"))) {

            return true;
        }

        return false;
    }

    public DriverPropertyInfo[] getPropertyInfo(String url, Properties info) throws SQLException {
        throw new UnsupportedOperationException("Not supported yet.");
    }

    public int getMajorVersion() {
        throw new UnsupportedOperationException("Not supported yet.");
    }

    public int getMinorVersion() {
        throw new UnsupportedOperationException("Not supported yet.");
    }

    public boolean jdbcCompliant() {
        throw new UnsupportedOperationException("Not supported yet.");
    }
}

Connection :

package com.raghu.jdbc;
import com.raghu.jdbc.nativeconnection.NativeConnection;
import java.sql.Array;
import java.sql.Blob;
import java.sql.CallableStatement;
import java.sql.Clob;
import java.sql.Connection;
import java.sql.DatabaseMetaData;
import java.sql.NClob;
import java.sql.PreparedStatement;
import java.sql.SQLClientInfoException;
import java.sql.SQLException;
import java.sql.SQLWarning;
import java.sql.SQLXML;
import java.sql.Savepoint;
import java.sql.Statement;
import java.sql.Struct;
import java.util.Map;
import java.util.Properties;
public class GenericConnection implements Connection {

    public Connection nativeConnection = null;

    public GenericConnection(Connection con) {
        nativeConnection = con;
    }

    public Statement createStatement() throws SQLException {
        System.out.println("inside 1----------");
        Statement st=nativeConnection.createStatement();
        return st;
    }

    public PreparedStatement prepareStatement(String sql) throws SQLException {
        System.out.println("inside 2----------");
        nativeConnection=new NativeConnection().getNativeConnection("jdbc:mysql://localhost:3306/","root", "root");
        PreparedStatement pst=nativeConnection.prepareStatement(sql);
        return pst;
    }

    public CallableStatement prepareCall(String sql) throws SQLException {
        CallableStatement cst=nativeConnection.prepareCall(sql);
        return cst;
    }

    public String nativeSQL(String sql) throws SQLException {
        System.out.println("inside 3----------");
        return nativeConnection.nativeSQL(sql);
    }

    public void setAutoCommit(boolean autoCommit) throws SQLException {
        nativeConnection.setAutoCommit(autoCommit);
    }

    public boolean getAutoCommit() throws SQLException {
        return nativeConnection.getAutoCommit();
    }

    public void commit() throws SQLException {
        nativeConnection.commit();
    }

    public void rollback() throws SQLException {
        nativeConnection.rollback();
    }

    public void close() throws SQLException {
        nativeConnection.close();
    }

    public boolean isClosed() throws SQLException {
        return nativeConnection.isClosed();
    }

    public DatabaseMetaData getMetaData() throws SQLException {
        return nativeConnection.getMetaData();
    }

    public void setReadOnly(boolean readOnly) throws SQLException {
        nativeConnection.setReadOnly(readOnly);
    }

    public boolean isReadOnly() throws SQLException {
        return nativeConnection.isReadOnly();
    }

    public void setCatalog(String catalog) throws SQLException {
        nativeConnection.setCatalog(catalog);
    }

    public String getCatalog() throws SQLException {
        return nativeConnection.getCatalog();
    }

    public void setTransactionIsolation(int level) throws SQLException {
        nativeConnection.setTransactionIsolation(level);
    }

    public int getTransactionIsolation() throws SQLException {
        return nativeConnection.getTransactionIsolation();
    }

    public SQLWarning getWarnings() throws SQLException {
        return nativeConnection.getWarnings();
    }

    public void clearWarnings() throws SQLException {
        nativeConnection.clearWarnings();
    }

    public Statement createStatement(int resultSetType, int resultSetConcurrency) throws SQLException {
        System.out.println("inside 4----------");
        return nativeConnection.createStatement(resultSetType, resultSetConcurrency);
    }

    public PreparedStatement prepareStatement(String sql, int resultSetType, int resultSetConcurrency) throws SQLException {
        System.out.println("inside 5----------");
       return nativeConnection.prepareStatement(sql, resultSetType,resultSetConcurrency);
    }

    public CallableStatement prepareCall(String sql, int resultSetType, int resultSetConcurrency) throws SQLException {
        return nativeConnection.prepareCall(sql, resultSetType, resultSetConcurrency);
    }

    public Map<String, Class<?>> getTypeMap() throws SQLException {
        return nativeConnection.getTypeMap();
    }

    public void setTypeMap(Map<String, Class<?>> map) throws SQLException {
        nativeConnection.setTypeMap(map);
    }

    public void setHoldability(int holdability) throws SQLException {
        nativeConnection.setHoldability(holdability);
    }

    public int getHoldability() throws SQLException {
        return nativeConnection.getHoldability();
    }

    public Savepoint setSavepoint() throws SQLException {
        return nativeConnection.setSavepoint();
    }

    public Savepoint setSavepoint(String name) throws SQLException {
        return nativeConnection.setSavepoint(name);
    }

    public void rollback(Savepoint savepoint) throws SQLException {
        nativeConnection.rollback(savepoint);
    }

    public void releaseSavepoint(Savepoint savepoint) throws SQLException {
        nativeConnection.releaseSavepoint(savepoint);
    }

    public Statement createStatement(int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SQLException {
        System.out.println("inside 6----------");
        return nativeConnection.createStatement(resultSetType, resultSetConcurrency, resultSetHoldability);
    }

    public PreparedStatement prepareStatement(String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SQLException {
        System.out.println("inside 7----------");
        return nativeConnection.prepareCall(sql, resultSetType, resultSetConcurrency);
    }

    public CallableStatement prepareCall(String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SQLException {
        return nativeConnection.prepareCall(sql, resultSetType, resultSetConcurrency, resultSetHoldability);
    }

    public PreparedStatement prepareStatement(String sql, int autoGeneratedKeys) throws SQLException {
        System.out.println("inside 8----------");
        return nativeConnection.prepareStatement(sql, autoGeneratedKeys);
    }

    public PreparedStatement prepareStatement(String sql, int[] columnIndexes) throws SQLException {
        System.out.println("inside 9----------");
      return nativeConnection.prepareStatement(sql, columnIndexes);
    }

    public PreparedStatement prepareStatement(String sql, String[] columnNames) throws SQLException {
        System.out.println("inside 10----------");
        return nativeConnection.prepareStatement(sql, columnNames);
    }

    public Clob createClob() throws SQLException {
        return nativeConnection.createClob();
    }

    public Blob createBlob() throws SQLException {
        return nativeConnection.createBlob();
    }

    public NClob createNClob() throws SQLException {
        return nativeConnection.createNClob();
    }

    public SQLXML createSQLXML() throws SQLException {
        return nativeConnection.createSQLXML();
    }

    public boolean isValid(int timeout) throws SQLException {
        return nativeConnection.isValid(timeout);
    }

    public void setClientInfo(String name, String value) throws SQLClientInfoException {
         nativeConnection.setClientInfo(name,value);
    }

    public void setClientInfo(Properties properties) throws SQLClientInfoException {
        nativeConnection.setClientInfo(properties);
    }

    public String getClientInfo(String name) throws SQLException {
       return nativeConnection.getClientInfo(name);
    }

    public Properties getClientInfo() throws SQLException {
       return nativeConnection.getClientInfo();
    }

    public Array createArrayOf(String typeName, Object[] elements) throws SQLException {
       return nativeConnection.createArrayOf(typeName, elements);
    }

    public Struct createStruct(String typeName, Object[] attributes) throws SQLException {
        return nativeConnection.createStruct(typeName, attributes);
    }

    public <T> T unwrap(Class<T> iface) throws SQLException {
        return nativeConnection.unwrap(iface);
    }

    public boolean isWrapperFor(Class<?> iface) throws SQLException {
       return nativeConnection.isWrapperFor(iface);
    }
}

Native connection :

package com.raghu.jdbc.nativeconnection;
import java.sql.ResultSet;
import java.sql.Statement;
public class NativeConnection {

    public static String dbflag = "simpledb";

    public java.sql.Connection getNativeConnection(String url, String dbuser, String dbpass) {
        System.out.println("\n ........getNativeConnection......\n");

        java.sql.Connection conn = null;
        String driver = "";
        try {

            driver = "com.mysql.jdbc.Driver";

            Class.forName(driver).newInstance();

            url = url + dbflag;
           // System.out.println("url.........");
            conn = java.sql.DriverManager.getConnection(url, dbuser, dbpass);


        } catch (Exception e) {
            e.printStackTrace();
        }
        System.out.println("\n ....getNativeConnection(con)......" + conn);
        return conn;
    }
}

H2 Database

noreply@blogger.com (Rambros) — Tue, 09 Jul 2013 12:21:00 +0000

Hello folks,

I was asked to do some encryption using java for some of the files that i create inside the product . I has a thought about using some in memory database and then dropped at "H2" , H2 seems to be promising and offers wide variety of solutions. You can use it as an embedded db, in memory db and also make it as server-client mode. The notable factor is performance that is offered in H2, seems it is at least twice than the rest.

Please refer the following URL to know more about H2 : http://www.h2database.com/html/main.html

Simple Example in Java :

import java.sql.*;
public class SampleHTwo {

    public static void main(String[] args) {
        Connection connection = null;
        ResultSet resultSet = null;
        Statement statement = null;
        try {
            Class.forName("org.h2.Driver");
            connection = DriverManager.getConnection("jdbc:h2:E:\\H2DB/test1;AUTO_SERVER=TRUE");
            statement = connection.createStatement();
            statement.execute("CREATE CACHED TABLE student(id INT PRIMARY KEY, name VARCHAR(255))");
           statement.execute("insert into student(id,name) values(2,'raghu')");
            resultSet = statement.executeQuery("SELECT name FROM student");
            while (resultSet.next()) {
                System.out.println("student NAME:" + resultSet.getString("name"));
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

Amazon-ElasticCache

noreply@blogger.com (Rambros) — Mon, 18 Mar 2013 13:05:00 +0000

Amazon ElastiCache

Amazon ElastiCache is a web service that makes it easy to deploy, operate, and scale an in-memory cache in the cloud.

The service improves the performance of web applications by allowing you to retrieve information from a fast, managed, in-memory caching system, instead of relying entirely on slower disk-based databases.

Amazon ElastiCache is protocol-compliant with Memcached, a widely adopted memory object caching system.

There are several merits of using elastic catch. There are, simple to deploy , easily managed , compatible , designed for use with other Amazon Web Services , secure and cost effective.

Amazon ElastiCache Functionality:

Use the Amazon ElastiCache APIs to launch a Cache Cluster selecting a Cache Cluster Name, Cache Node Type and Number of Nodes that best meets our needs.
Connect to your Cache Nodes using your favorite Memcached clients or Programming language.
Get detailed monitoring statistics of our Cache Nodes for no additional charge via Amazon CloudWatch.
If at any point we need additional capacity, we can add more Cache Nodes to our Cache Cluster with a simple API call.
Pay only for the resources you actually consume, based on our Cache Node hours used.

Features:

Pre-configured Parameters
Automatic failure detection and recovery
Detailed Monitoring and Metrics
Automatic Software Patching
Push-Button Scaling

Amazon ElastiCache Cache Node Types:

Micro
Standard
Enhanced
High-Memory
High-CPU

Lets see a sample Java Code for this implementation,

import net.spy.memcached.MemcachedClient;
import java.net.InetSocketAddress;
import java.io.IOException;
/**
*
* @author Raghu
*/
public class ElastiCache {

    /**
     * @param args the command line arguments
     */
    public static void main(String[] args) {
        // TODO code application logic here

        try {
        //127.0.0.1 - machine's ip
        //11211 - port in which memcache server running

        MemcachedClient c = new MemcachedClient(new InetSocketAddress("cachetest.7hpjru.cfg.use1.cache.amazonaws.com", 11211));
        ///MemcachedClient c = new MemcachedClient(new InetSocketAddress("cachetest.7hpjru.0001.use1.cache.amazonaws.com", 11211));

        String s = "ElastiCache";
        c.set("someKey", 3600, s);

        Object myObject = c.get("someKey");
        System.out.println("\n myobject---->" + myObject.toString());
        //c.delete("someKey");

    } catch (IOException ex) {
        ex.printStackTrace();
    }

    }

}

OpenStack - API Implementations

noreply@blogger.com (Rambros) — Mon, 18 Mar 2013 13:02:00 +0000

What is OpenStack?

OpenStack is a global collaboration of developers and cloud computing
technologists producing the open standard cloud computing platform for both public
and private clouds. The project aims to deliver solutions for all types of clouds by
being simple to implement, massively scalable, and feature rich. The technology
consists of a series of interrelated projects delivering various components for a
cloud infrastructure solution.

Here we shall see the required API implementations,

OPENSTACK Compute API using RestConsole v4.0.2

Step 1: To generate base token.

URI Syntax : http://<IP>:5000/v2.0/tokens

URI Eg: http://172.16.0.1:5000/v2.0/tokens

Method : POST

Content-Type: applicaiton/json

Request Body : {"auth":{"passwordCredentials":{"username": "admin", "password":"openstack"}, "tenantId":""}}

Response json :-

{

"access": {

"token": {

"expires": "2013-01-10T13:17:31Z",

"id": "9a92e97e52d9443896d130bb85714aaa"

"serviceCatalog": {},

"user": {

"username": "admin",

"roles_links": [],

"id": "0425c7dbae134d7bb9f6c5774c71e509",

"roles": [],

"name": "admin"

}

Result : We have obtained one base (Eg : "9a92e97e52d9443896d130bb85714aaa") token and these token helps to find projectID(tenantID).

Step 2: To find tenantID(projectID) using above generated base token.

URI Syntax : http://<IP>:5000/v2.0/tenants

URI Eg: http://172.16.0.1:5000/v2.0/tenants

Method : GET

Content-Type: applicaiton/json

Request Body : {"auth":{"passwordCredentials":{"username": "admin", "password":"openstack"}, "tenantId":""}}

Headers Param : X-Auth-Token(header) – 9a92e97e52d9443896d130bb85714aaa(value)

Response json :-

{

"tenants_links": [],

"tenants": [{

"enabled": true,

"description": "Default Tenant",

"name": "practiceproject",

"id": "22708001d9454cc9a38d195622bf1ee1"

}]

}

Result : Now we got tenantIDs Eg: "22708001d9454cc9a38d195622bf1ee1".

After that we need to generate tenant specific token using above generated tenantID with base token.

Step 3: To find tenant specific token.

URI Syntax : http://<IP>:5000/v2.0/tokens

URI Eg: http://172.16.0.1:5000/v2.0/tokens

Method : POST

Content-Type: applicaiton/json

Request Body : {"auth":{"passwordCredentials":{"username": "admin", "password":"openstack"}, "tenantId":"22708001d9454cc9a38d195622bf1ee1"}}

Headers Param : X-Auth-Token(header) – 9a92e97e52d9443896d130bb85714aaa(value)

Response json :-

{

"access": {

"token": {

"expires": "2013-01-10T13:22:32Z",

"id": "e57565d9db2144e6b3262d75d65eca72",

"tenant": {

"description": "Default Tenant",

"enabled": true,

"id": "22708001d9454cc9a38d195622bf1ee1",

"name": "practiceproject"

}

"serviceCatalog": [{

"endpoints": [{

"adminURL": "http://172.16.0.1:8774/v2/22708001d9454cc9a38d195622bf1ee1",

"region": "nova",

"internalURL": "http://172.16.0.1:8774/v2/22708001d9454cc9a38d195622bf1ee1",

"publicURL": "http://172.16.0.1:8774/v2/22708001d9454cc9a38d195622bf1ee1"

}],

"endpoints_links": [],

"type": "compute",

"name": "nova"

}, {

"endpoints": [{

"adminURL": "http://172.16.0.1:9292/v1",

"region": "nova",

"internalURL": "http://172.16.0.1:9292/v1",

"publicURL": "http://172.16.0.1:9292/v1"

}],

"endpoints_links": [],

"type": "image",

"name": "glance"

}, {

"endpoints": [{

"adminURL": "http://172.16.0.1:8776/v1/22708001d9454cc9a38d195622bf1ee1",

"region": "nova",

"internalURL": "http://172.16.0.1:8776/v1/22708001d9454cc9a38d195622bf1ee1",

"publicURL": "http://172.16.0.1:8776/v1/22708001d9454cc9a38d195622bf1ee1"

}],

"endpoints_links": [],

"type": "volume",

"name": "volume"

}, {

"endpoints": [{

"adminURL": "http://172.16.0.1:8773/services/Admin",

"region": "nova",

"internalURL": "http://172.16.0.1:8773/services/Cloud",

"publicURL": "http://172.16.0.1:8773/services/Cloud"

}],

"endpoints_links": [],

"type": "ec2",

"name": "ec2"

}, {

"endpoints": [{

"adminURL": "https://172.16.0.1:443/v1",

"region": "nova",

"internalURL": "https://172.16.0.1:443/v1/AUTH_22708001d9454cc9a38d195622bf1ee1",

"publicURL": "https://172.16.0.1:443/v1/AUTH_22708001d9454cc9a38d195622bf1ee1"

}],

"endpoints_links": [],

"type": "object-store",

"name": "swift"

}, {

"endpoints": [{

"adminURL": "http://172.16.0.1:35357/v2.0",

"region": "nova",

"internalURL": "http://172.16.0.1:5000/v2.0",

"publicURL": "http://172.16.0.1:5000/v2.0"

}],

"endpoints_links": [],

"type": "identity",

"name": "keystone"

}],

"user": {

"username": "admin",

"roles_links": [],

"id": "0425c7dbae134d7bb9f6c5774c71e509",

"roles": [{

"id": "fa4e161c9cda4ef7ac722d05c91864a8",

"name": "admin"

}, {

"id": "e427252a86e54c79848213d4a52fbaa9",

"name": "swiftoperator"

}, {

"id": "6f50e339568c488ab8d22c027e0dc9b2",

"name": "Member"

}],

"name": "admin"

}

Result : Finally, we got tenant specific token, Eg: token - e57565d9db2144e6b3262d75d65eca72 and tenantID - 22708001d9454cc9a38d195622bf1ee1

Henceforth, We move forward with the help of tenant specific token.

To List out all images :-

List of all the images available in machine.

Syntax : http://<IP>:8774/v2/<tenantID>/images

URI Eg : http://172.16.0.1:8774/v2/22708001d9454cc9a38d195622bf1ee1/images

Method : GET

Content Type : application/json

X-Auth-Token : e57565d9db2144e6b3262d75d65eca72

Response json :-

{

"images": [{

"id": "e7fd53c9-08a1-4702-8544-aab7876c89ca",

"links": [{

"href": "http://172.16.0.1:8774/v2/22708001d9454cc9a38d195622bf1ee1/images/e7fd53c9-08a1-4702-8544-aab7876c89ca",

"rel": "self"

}, {

"href": "http://172.16.0.1:8774/22708001d9454cc9a38d195622bf1ee1/images/e7fd53c9-08a1-4702-8544-aab7876c89ca",

"rel": "bookmark"

}, {

"href": "http://10.0.2.15:9292/22708001d9454cc9a38d195622bf1ee1/images/e7fd53c9-08a1-4702-8544-aab7876c89ca",

"type": "application/vnd.openstack.image",

"rel": "alternate"

}],

"name": "images/precise-server-cloudimg-i386.img"

}, {

"id": "7d450eea-cbbe-4725-84f5-05a133160e53",

"links": [{

"href": "http://172.16.0.1:8774/v2/22708001d9454cc9a38d195622bf1ee1/images/7d450eea-cbbe-4725-84f5-05a133160e53",

"rel": "self"

}, {

"href": "http://172.16.0.1:8774/22708001d9454cc9a38d195622bf1ee1/images/7d450eea-cbbe-4725-84f5-05a133160e53",

"rel": "bookmark"

}, {

"href": "http://10.0.2.15:9292/22708001d9454cc9a38d195622bf1ee1/images/7d450eea-cbbe-4725-84f5-05a133160e53",

"type": "application/vnd.openstack.image",

"rel": "alternate"

}],

"name": "images/centos.5-3.x86-64.img"

}, {

"id": "90289f36-c108-405a-9f0e-e7f02c918063",

"links": [{

"href": "http://172.16.0.1:8774/v2/22708001d9454cc9a38d195622bf1ee1/images/90289f36-c108-405a-9f0e-e7f02c918063",

"rel": "self"

}, {

"href": "http://172.16.0.1:8774/22708001d9454cc9a38d195622bf1ee1/images/90289f36-c108-405a-9f0e-e7f02c918063",

"rel": "bookmark"

}, {

"href": "http://10.0.2.15:9292/22708001d9454cc9a38d195622bf1ee1/images/90289f36-c108-405a-9f0e-e7f02c918063",

"type": "application/vnd.openstack.image",

"rel": "alternate"

}],

"name": "images/vmlinuz-2.6.28-11-generic"

}, {

"id": "14359fcc-0762-43aa-a997-43f5a2d5c790",

"links": [{

"href": "http://172.16.0.1:8774/v2/22708001d9454cc9a38d195622bf1ee1/images/14359fcc-0762-43aa-a997-43f5a2d5c790",

"rel": "self"

}, {

"href": "http://172.16.0.1:8774/22708001d9454cc9a38d195622bf1ee1/images/14359fcc-0762-43aa-a997-43f5a2d5c790",

"rel": "bookmark"

}, {

"href": "http://10.0.2.15:9292/22708001d9454cc9a38d195622bf1ee1/images/14359fcc-0762-43aa-a997-43f5a2d5c790",

"type": "application/vnd.openstack.image",

"rel": "alternate"

}],

"name": "ubuntu 12.04 amd64 Kernel"

}]

}

To List Particular Image :-

Syntax : http://<IP>:8774/v2/<tenantID>/images?name=<imagename>

URI Eg : http://172.16.0.1:8774/v2/22708001d9454cc9a38d195622bf1ee1/images?name=images/centos.5-3.x86-64.img

(or)

We can get through specific image ID with details as well :

Syntax : http://<IP>:8774/v2/<tenantID>/images/<imageID>

URI Eg : http://172.16.0.1:8774/v2/22708001d9454cc9a38d195622bf1ee1/images/7d450eea-cbbe-4725-84f5-05a133160e53

Method : GET

Content Type : application/json

X-Auth-Token : e57565d9db2144e6b3262d75d65eca72

List of all flavors :-

List of all the flavors created in machine.

Syntax : http://<IP>:8774/v2/<tenantID>/flavors

URI Eg : http://172.16.0.1:8774/v2/22708001d9454cc9a38d195622bf1ee1/flavors

Method : GET

Content Type : application/json

X-Auth-Token : e57565d9db2144e6b3262d75d65eca72

Response json :-

{

"flavors": [{

"id": "2",

"links": [{

"href": "http://172.16.0.1:8774/v2/22708001d9454cc9a38d195622bf1ee1/flavors/2",

"rel": "self"

}, {

"href": "http://172.16.0.1:8774/22708001d9454cc9a38d195622bf1ee1/flavors/2",

"rel": "bookmark"

}],

"name": "m1.small"

}, {

"id": "3",

"links": [{

"href": "http://172.16.0.1:8774/v2/22708001d9454cc9a38d195622bf1ee1/flavors/3",

"rel": "self"

}, {

"href": "http://172.16.0.1:8774/22708001d9454cc9a38d195622bf1ee1/flavors/3",

"rel": "bookmark"

}],

"name": "m1.medium"

}, {

"id": "4",

"links": [{

"href": "http://172.16.0.1:8774/v2/22708001d9454cc9a38d195622bf1ee1/flavors/4",

"rel": "self"

}, {

"href": "http://172.16.0.1:8774/22708001d9454cc9a38d195622bf1ee1/flavors/4",

"rel": "bookmark"

}],

"name": "m1.large"

}, {

"id": "5",

"links": [{

"href": "http://172.16.0.1:8774/v2/22708001d9454cc9a38d195622bf1ee1/flavors/5",

"rel": "self"

}, {

"href": "http://172.16.0.1:8774/22708001d9454cc9a38d195622bf1ee1/flavors/5",

"rel": "bookmark"

}],

"name": "m1.xlarge"

}, {

"id": "6",

"links": [{

"href": "http://172.16.0.1:8774/v2/22708001d9454cc9a38d195622bf1ee1/flavors/6",

"rel": "self"

}, {

"href": "http://172.16.0.1:8774/22708001d9454cc9a38d195622bf1ee1/flavors/6",

"rel": "bookmark"

}],

"name": "m1.tiny"

}, {

"id": "7",

"links": [{

"href": "http://172.16.0.1:8774/v2/22708001d9454cc9a38d195622bf1ee1/flavors/7",

"rel": "self"

}, {

"href": "http://172.16.0.1:8774/22708001d9454cc9a38d195622bf1ee1/flavors/7",

"rel": "bookmark"

}],

"name": "m1.tiny1"

}]

}

Particular flavors ID :-

Syntax : http://<IP>:8774/v2/<tenantID>/flavors/<flavorsID>

URI Eg : http://172.16.0.1:8774/v2/22708001d9454cc9a38d195622bf1ee1/flavors/7

Method : GET

Content Type : application/json

X-Auth-Token : e57565d9db2144e6b3262d75d65eca72

Launch Instance :-

Syntax : http://<IP>:8774/v2/<tenantID>/servers

URI Eg : http://172.16.0.1:8774/v2/22708001d9454cc9a38d195622bf1ee1/servers

Method : POST

Request Body :

{

"server" : {

"name" : "hemAPItrailserver",

"imageRef" : "e7fd53c9-08a1-4702-8544-aab7876c89ca",

"flavorRef" : "7"

}

Content Type : application/json

X-Auth-Token : e57565d9db2144e6b3262d75d65eca72

Response json:-

{

"server": {

"OS-DCF:diskConfig": "MANUAL",

"id": "d1ecd84b-c8f6-450d-9050-81d583a2a28f",

"links": [{

"href": "http://172.16.0.1:8774/v2/22708001d9454cc9a38d195622bf1ee1/servers/d1ecd84b-c8f6-450d-9050-81d583a2a28f",

"rel": "self"

}, {

"href": "http://172.16.0.1:8774/22708001d9454cc9a38d195622bf1ee1/servers/d1ecd84b-c8f6-450d-9050-81d583a2a28f",

"rel": "bookmark"

}],

"adminPass": "BzAZQih2dEg2"

}

Update Instance :-

Syntax : http://<IP>:8774/v2/<tenantID>/servers/<serverID>

URI Eg : http://172.16.0.1:8774/v2/22708001d9454cc9a38d195622bf1ee1/servers/ d1ecd84b-c8f6-450d-9050-81d583a2a28f

Method : PUT

Request Body :

{

"server" :

{

"name" : "modifyHemTrailServer"

}

Content Type : application/json

X-Auth-Token : e57565d9db2144e6b3262d75d65eca72

List of all servers :-

Syntax : http://<IP>:8774/v2/<tenantID>/servers

URI Eg : http://172.16.0.1:8774/v2/22708001d9454cc9a38d195622bf1ee1/servers

Method : GET

Content Type : application/json

X-Auth-Token : e57565d9db2144e6b3262d75d65eca72

Response json :-

{

"servers": [{

"id": "93d1dc7e-bfd9-4a4e-8afe-2416c653a732",

"links": [{

"href": "http://172.16.0.1:8774/v2/22708001d9454cc9a38d195622bf1ee1/servers/93d1dc7e-bfd9-4a4e-8afe-2416c653a732",

"rel": "self"

}, {

"href": "http://172.16.0.1:8774/22708001d9454cc9a38d195622bf1ee1/servers/93d1dc7e-bfd9-4a4e-8afe-2416c653a732",

"rel": "bookmark"

}],

"name": "trailserver"

}, {

"id": "88dd37e7-bc90-4991-84c9-610fde493e3d",

"links": [{

"href": "http://172.16.0.1:8774/v2/22708001d9454cc9a38d195622bf1ee1/servers/88dd37e7-bc90-4991-84c9-610fde493e3d",

"rel": "self"

}, {

"href": "http://172.16.0.1:8774/22708001d9454cc9a38d195622bf1ee1/servers/88dd37e7-bc90-4991-84c9-610fde493e3d",

"rel": "bookmark"

}],

"name": "final"

}]

}

Particular server :-

Syntax : http://<IP>:8774/v2/<tenantID>/servers?name=<servername>

URI Eg : http://172.16.0.1:8774/v2/22708001d9454cc9a38d195622bf1ee1/servers?name=trailserver

Method : GET

Content Type : application/json

X-Auth-Token : e57565d9db2144e6b3262d75d65eca72

Open Stack Server Actions :-

************************

reboot the instance :-

*****************

Syntax : http://<IP>:8774/v2/<tenantID>/servers/<serverID>/action

URI Eg: http://172.16.0.1:8774/v2/22708001d9454cc9a38d195622bf1ee1/servers/d1ecd84b-c8f6-450d-9050-81d583a2a28f/action

Method : POST

Request body :

{

"reboot" : {

"type" : "HARD"

}

Content Type : application/json

X-Auth-Token : e57565d9db2144e6b3262d75d65eca72

Suspend and pause the instance :-

***************************

Syntax : http://<IP>:8774/v2/<tenantID>/servers/<serverID>/action

URI Eg: http://172.16.0.1:8774/v2/22708001d9454cc9a38d195622bf1ee1/servers/d1ecd84b-c8f6-450d-9050-81d583a2a28f/action

Method : POST

Request body for Suspend:-

{

"suspend" : null

}

Content Type : application/json

X-Auth-Token : e57565d9db2144e6b3262d75d65eca72

Request body for resume :-

{

"resume" : null

}

Request body for Pause :-

{
    "pause": null
}

Request body for Unpause:-

{
    "unpause": null
}

Delete Instance (Terminate) :-

Syntax : http://<IP>:8774/v2/<tenantID>/servers/<serverID>

URI Eg: http://172.16.0.1:8774/v2/22708001d9454cc9a38d195622bf1ee1/servers/d1ecd84b-c8f6-450d-9050-81d583a2a28f

Method : DELETE

Content Type : application/json

X-Auth-Token : e57565d9db2144e6b3262d75d65eca72

Create an Image of specified server (Instance's Image Backup):-

Syntax : http://<IP>:8774/v2/<tenantID>/servers/<serverID>/action

URI Eg: http://172.16.0.1:8774/v2/22708001d9454cc9a38d195622bf1ee1/servers/70c5c067-c35f-4401-917f-3de5fbd1daaa/action

Method : POST

Request Body :-

{

"createImage" : {

"name" : "newImageViaAPI"

}

Content Type : application/json

X-Auth-Token : e57565d9db2144e6b3262d75d65eca72

Delete an Image of specified server :-

Syntax : http://<IP>:8774/v2/<tenantID>/images/<imageID>

URI Eg: http://172.16.0.1:8774/v2/22708001d9454cc9a38d195622bf1ee1/images/8bbcef8a-4583-4cb3-98c6-4cfa8991084d

Method : DELETE

Content Type : application/json

X-Auth-Token : e57565d9db2144e6b3262d75d65eca72

Block Storage service (Volumn) :-

Allows you to manage volumes and snapshots that can be used with the Volume API (nova-volume or cinder services)

To Create a Volume :-

Syntax : http://<IP>:8776/v1/<tenantID>/volumes

URI Eg : http://172.16.0.1:8776/v1/22708001d9454cc9a38d195622bf1ee1 /volumes

Method : POST

Request Body :

{
    "volume": {
        "display_name": "vol-001",
        "display_description": "volume1test",
        "size": 2,
        "volume_type": "",
        "metadata": {},
        "availability_zone": ""
     }
}

Content Type : application/json

X-Auth-Token : e57565d9db2144e6b3262d75d65eca72

Response json :-

{

"volume": {

"status": "creating",

"display_name": "vol-001",

"attachments": [],

"availability_zone": "",

"created_at": "2013-01-23 12:03:30.807734",

"display_description": "volume1test",

"volume_type": "None",

"snapshot_id": null,

"size": 2,

"id": "5",

"metadata": {}

}

To List out of all Volumes :-

Syntax : http://<IP>:8776/v1/<tenantID>/volumes

URI Eg : http://172.16.0.1:8776/v1/22708001d9454cc9a38d195622bf1ee1 /volumes

Method : GET

Request Body :

{"auth":{"passwordCredentials":{"username": "admin", "password":"openstack"}, "tenantId":"22708001d9454cc9a38d195622bf1ee1"}}

Content Type : application/json

X-Auth-Token : e57565d9db2144e6b3262d75d65eca72

Response json :

{

"volumes": [{

"status": "in-use",

"display_name": "aaaaaaa",

"attachments": [{

"device": "/dev/vdc",

"server_id": "ad59de63-4cb3-4152-af9e-885e6e35bf71",

"id": "2",

"volume_id": "2"

}],

"availability_zone": "nova",

"created_at": "2013-01-22 09:38:49",

"display_description": "aaaa",

"volume_type": "None",

"snapshot_id": null,

"size": 1,

"id": "2",

"metadata": {}

}, {

"status": "in-use",

"display_name": "bbbbbb",

"attachments": [{

"device": "/dev/vdd",

"server_id": "7ba09533-81f7-4a40-bf16-44edf6d7b400",

"id": "3",

"volume_id": "3"

}],

"availability_zone": "nova",

"created_at": "2013-01-22 12:37:59",

"display_description": "test",

"volume_type": "None",

"snapshot_id": null,

"size": 2,

"id": "3",

"metadata": {}

}, {

"status": "available",

"display_name": "vol-001",

"attachments": [],

"availability_zone": "",

"created_at": "2013-01-23 12:03:30",

"display_description": "volume1test",

"volume_type": "None",

"snapshot_id": null,

"size": 2,

"id": "5",

"metadata": {}

}]

}

To get particular volume :-

Syntax : http://<IP>:8776/v1/<tenantID>/volumes/<volumeID>

URI Eg : http://172.16.0.1:8776/v1/22708001d9454cc9a38d195622bf1ee1 /volumes/5

Method : GET

Request Body :

{"auth":{"passwordCredentials":{"username": "admin", "password":"openstack"}, "tenantId":"22708001d9454cc9a38d195622bf1ee1"}}

Content Type : application/json

X-Auth-Token : e57565d9db2144e6b3262d75d65eca72

Response json :-

{

"volume": {

"status": "available",

"display_name": "vol-001",

"attachments": [],

"availability_zone": "",

"created_at": "2013-01-23 12:03:30",

"display_description": "volume1test",

"volume_type": "None",

"snapshot_id": null,

"size": 2,

"id": "5",

"metadata": {}

}

To get Volume Types :-

Syntax : http://<IP>:8776/v1/<tenantID>/types

URI Eg : http://172.16.0.1:8776/v1/22708001d9454cc9a38d195622bf1ee1 /types

Method : GET

Request Body :

{"auth":{"passwordCredentials":{"username": "admin", "password":"openstack"}, "tenantId":"22708001d9454cc9a38d195622bf1ee1"}}

Content Type : application/json

X-Auth-Token : e57565d9db2144e6b3262d75d65eca72

To create volume snapshot :-

Syntax : http://<IP>:8776/v1/<tenantID>/snapshots

URI Eg : http://172.16.0.1:8776/v1/22708001d9454cc9a38d195622bf1ee1 /snapshots

Method : POST

Request Body :

{
    "snapshot": {
        "display_name": "snap-001",
        "display_description": "Daily backup",
        "volume_id": "5",
        "force": true
     }
}

Content Type : application/json

X-Auth-Token : e57565d9db2144e6b3262d75d65eca72

Response json :

{

"snapshot": {

"status": "creating",

"display_name": "snap-001",

"created_at": "2013-01-23 12:19:52.411395",

"display_description": "Daily backup",

"volume_id": "5",

"id": "1",

"size": 2

}

To List out of all snapshots :-

Syntax : http://<IP>:8776/v1/<tenantID>/snapshots

URI Eg : http://172.16.0.1:8776/v1/22708001d9454cc9a38d195622bf1ee1 /snapshots

Method : GET

Request Body :

{"auth":{"passwordCredentials":{"username": "admin", "password":"openstack"}, "tenantId":"22708001d9454cc9a38d195622bf1ee1"}}

Content Type : application/json

X-Auth-Token : e57565d9db2144e6b3262d75d65eca72

Response json:-

{

"snapshots": [{

"status": "available",

"display_name": "snap-001",

"created_at": "2013-01-23 12:19:52",

"display_description": "Daily backup",

"volume_id": "5",

"id": "1",

"size": 2

}]

}

To delete particular snapshots :-

Syntax : http://<IP>:8776/v1/<tenantID>/snapshots/<snapshotsID>

URI Eg : http://172.16.0.1:8776/v1/22708001d9454cc9a38d195622bf1ee1 /snapshots/1

Method : DELETE

Content Type : application/json

X-Auth-Token : e57565d9db2144e6b3262d75d65eca72

Response json :- Doesnot return any response, shows empty.

To delete particular volume :-

Syntax : http://<IP>:8776/v1/<tenantID>/volumes/<volumesID>

URI Eg : http://172.16.0.1:8776/v1/22708001d9454cc9a38d195622bf1ee1 /volumes/5

Method : DELETE

Content Type : application/json

X-Auth-Token : e57565d9db2144e6b3262d75d65eca72

Response json :- Doesnot return any response, shows empty.

To create volume attachments with server :-

Syntax : http://<IP>:8774/v2/<tenantID>/servers/<serverID>/os-volume_attachments

URI Eg : http://172.16.0.1:8776/v1/22708001d9454cc9a38d195622bf1ee1 /servers/d1ecd84b-c8f6-450d-9050-81d583a2a28f/os-volume_attachments

Method : POST

Request Body :

{"volumeAttachment": {"volumeId":"5", "device": "dev/vdd"} }

Content Type : application/json

X-Auth-Token : e57565d9db2144e6b3262d75d65eca72

To list of all volume attached with particular servers :-

Syntax : http://<IP>:8774/v2/<tenantID>/servers/<serverID>/os-volume_attachments

URI Eg : http://172.16.0.1:8776/v1/22708001d9454cc9a38d195622bf1ee1 /servers/d1ecd84b-c8f6-450d-9050-81d583a2a28f/os-volume_attachments

Method : GET

Request Body :

{"auth":{"passwordCredentials":{"username": "admin", "password":"openstack"}, "tenantId":"22708001d9454cc9a38d195622bf1ee1"}}

Content Type : application/json

X-Auth-Token : e57565d9db2144e6b3262d75d65eca72

Response json:-

{

"volumeAttachments": [{

"device": "/dev/vdd",

"serverId": "7ba09533-81f7-4a40-bf16-44edf6d7b400",

"id": 3,

"volumeId": 3

}]

}

To get particular volume attached with particular server :-

Syntax : http://<IP>:8774/v2/<tenantID>/servers/<serverID>/os-volume_attachments/<volumeID>

URI Eg : http://172.16.0.1:8776/v1/22708001d9454cc9a38d195622bf1ee1 /servers/d1ecd84b-c8f6-450d-9050-81d583a2a28f/os-volume_attachments/5

Method : GET

Request Body :

{"auth":{"passwordCredentials":{"username": "admin", "password":"openstack"}, "tenantId":"22708001d9454cc9a38d195622bf1ee1"}}

Content Type : application/json

X-Auth-Token : e57565d9db2144e6b3262d75d65eca72

Response json :-

{

"volumeAttachment": {

"device": "/dev/vdd",

"serverId": "7ba09533-81f7-4a40-bf16-44edf6d7b400",

"id": 3,

"volumeId": 3

}

To detachment from particular server :-

Syntax : http://<IP>:8774/v2/<tenantID>/servers/<serverID>/os-volume_attachments/<volumeID>

URI Eg : http://172.16.0.1:8776/v1/22708001d9454cc9a38d195622bf1ee1 /servers/d1ecd84b-c8f6-450d-9050-81d583a2a28f/os-volume_attachments/5

Method : DELETE

Content Type : application/json

X-Auth-Token : e57565d9db2144e6b3262d75d65eca72

To Allocate Floating IP to project(tenant):-

Syntax : http://<IP>:8774/v2/<tenantID>/os-floating-ips

URI Eg : http://172.16.0.1:8776/v1/22708001d9454cc9a38d195622bf1ee1 /os-floating-ips

Method : POST

Request Body :

{
    "pool": "nova"
}

Content Type : application/json

X-Auth-Token : e57565d9db2144e6b3262d75d65eca72

To list out all of the floating Ips allocated with particular project(tenant) :-

Syntax : http://<IP>:8774/v2/<tenantID>/os-floating-ips

URI Eg : http://172.16.0.1:8776/v1/22708001d9454cc9a38d195622bf1ee1 /os-floating-ips

Method : GET

Request Body :

{"auth":{"passwordCredentials":{"username": "admin", "password":"openstack"}, "tenantId":"22708001d9454cc9a38d195622bf1ee1"}}

Content Type : application/json

X-Auth-Token : e57565d9db2144e6b3262d75d65eca72

To add floating IP to particular server :-

Syntax : http://<IP>:8774/v2/<tenantID>/servers/<serverID>/action

URI Eg : http://172.16.0.1:8776/v1/22708001d9454cc9a38d195622bf1ee1 /servers/d1ecd84b-c8f6-450d-9050-81d583a2a28f/action

Method : POST

Request Body :

{
    "addFloatingIp": {
        "address": "10.10.10.1"
    }
}

Content Type : application/json

X-Auth-Token : e57565d9db2144e6b3262d75d65eca72

To remove floating IP from particular server :-

Syntax : http://<IP>:8774/v2/<tenantID>/servers/<serverID>/action

URI Eg : http://172.16.0.1:8776/v1/22708001d9454cc9a38d195622bf1ee1 /servers/d1ecd84b-c8f6-450d-9050-81d583a2a28f/action

Method : POST

Request Body :

{
    "removeFloatingIp": {
        "address": "10.10.10.1"
    }
}

Content Type : application/json

X-Auth-Token : e57565d9db2144e6b3262d75d65eca72

To de-allocates the floating IP from particular project(tenant) :-

Syntax : http://<IP>:8774/v2/<tenantID>/os-floating-ips

URI Eg : http://172.16.0.1:8776/v1/22708001d9454cc9a38d195622bf1ee1 /os-floating-ips

Method : DELETE

Content Type : application/json

X-Auth-Token : e57565d9db2144e6b3262d75d65eca72

==========*********==========

Reference Link :-

http://docs.openstack.org/api/quick-start/content/

http://docs.openstack.org/api/openstack-compute/2/content/API_Operations-d1e2068.html

http://docs.openstack.org/api/openstack-identity-service/2.0/content/api_operations.html

http://api.openstack.org/api-ref.html

Cloudify with API

noreply@blogger.com (Rambros) — Mon, 18 Mar 2013 12:56:00 +0000

Cloudify provides Rest API to deploy,launch,scale the applications. There are many API's like getting log or information about the deployed application in the site. Our POC explains a very few of those. For Complete list of API please refer http://www.cloudifysource.org/guide/2.2/restapi/restdoclet.html

Cloudify provides Rest API support from different server rather than Management Web Console. Management Console usually run in <machine>:8099 and RestFull service will be available in <machine>:8100

Deployed Applications Details (Using GET method):

No Parameters Required

http://50.17.100.161:8100/service/applications

Deployed services for a Application (Using GET method):

Parameters : application name(example: helloworld )

http://50.17.100.161:8100/service/applications/<appname>/services

Deployed service Instance Information (Using GET method):

Parameters : application name(example: helloworld ),service name(example:tomcat)

http://50.17.100.161:8100/service/applications/<appname>/services/<servicename>/instances

Deploy and Launch Application (Using Post Method):

Here we have zip to application folder with all the required recipes, send that zip folder as one of the request parameter.

parameters :application name(example: helloworld )

post body params :

MultipartEntity multiPartEntity = new MultipartEntity();

FileBody fileBody = new FileBody(new File(path));

multiPartEntity.addPart("file", fileBody);

httpRequest.setEntity(multiPartEntity);

http://50.17.100.161:8100/service/applications/<appname>/timeout/50

Unistall Application (Using Delete Method):

parameters :application name(example: helloworld )

http://50.17.100.161:8100/service/applications/<appname>/timeout/50

Scale-Up and Scale-Down Application (Using Post Method):

Parameters : application name(example: helloworld ),service name(example:tomcat)

post body params example:

nameValuePairs.add(new BasicNameValuePair("count", Integer.toString(2)));

nameValuePairs.add(new BasicNameValuePair("location-aware", Boolean.toString(true)));

httpRequest.setEntity(new UrlEncodedFormEntity(nameValuePairs));

http://50.17.100.161:8100/service/applications/<appname>/services/<servicename>/timeout/50/set-instances

Custom command invocation (Using Post Method):

Parameters : application name(example: helloworld ),service name(example:tomcat),JsonParams(example:"{"GS_USM_Command_Parameters0":"http://50.17.100.161:8181/webdav/patch.zip","GS_USM_CommandName":"runpatch"}")

post body params example:

   HttpPost httpRequest = new HttpPost(url);
   StringEntity rr = new StringEntity(jsonparams, "application/json", "UTF-8");
   httpRequest.setEntity(rr);

http://50.17.100.161:8100/service/applications/<appname>/services/<servicename>/beans/universalServiceManagerBean/invoke

Cloudify

noreply@blogger.com (Rambros) — Mon, 18 Mar 2013 12:52:00 +0000

What is Cloudify?

Cloudify is an enterprise-class open source PaaS stack (Platform as a Service) that sits between your application and your chosen cloud. It enables your application to concentrate on doing what it does best, leaving Cloudify to ensure that the resources it needs are available regardless of the cloud and stack used.
Enterprise-class means refers to hardware and software that provides high speed and high reliability.

Cloudify is designed to offer the following features:

Any App, Any Stack - Deploy any middle ware stack using a recipe based deployment mechanism
Automation of the Entire Lifecycle - Deploy, manage, and update your application using a single platform
Automatic Self-Healing - Crashed nodes and machines are automatically replaced by new ones, following recipe instructions
Auto-Scale, Your Way - Automatic scaling of your application services based on out-of-the-box or custom metrics. Scale-in or scale-out!
Any Cloud - Support all major cloud and virtualization platforms. Your application is completely decoupled from the cloud API
Cluster-Aware Monitoring & Performance Management - Plug-gable monitoring, collects tier and application KPIs (Key Performance Indicators).
Fully Testable on Your Laptop - Easily start, debug & test on your laptop with a fully functional cloud emulator. No VMs, no hassles!

Install the Cloudify shell:

Where do i get cloudify :
http://www.cloudifysource.org/downloads/get_cloudify

How do i install cloudify :
You can refer the guide provided in the cloudify site, we have also tried to explain with a sample in this page.
http://www.cloudifysource.org/guide/

How Cloudify Works?

It Treats your infrastructure similar to code.
As a result, deploying and managing your application becomes a simple process:

Prepare your deployment
Deploy the services and application
Monitor and manage the deployment using the Cloudify web management console or the Cloudify shell

What is Recipe?

Cloudify operates through a concept called recipe, the original term recipe means a preparation procedure or required items. Cloudify chooses that kind of mechanism.

A set of instructions for how to cook your app on the cloud.

A recipe describes application inter dependencies between tiers (services), the entire deployment process for provisioning each tier, and post-deployment tasks such as monitoring KPIs, fail over handling, and the rules for self-healing and scaling.

We will see more about the cloudify in next post

Cron Example

noreply@blogger.com (Rambros) — Mon, 25 Jun 2012 09:56:00 +0000

Hi all,

I was working with Cron scheduling and with some help from the internet blogs finally i made a example out of it. Please refer the following website for full explanation http://www.mkyong.com/java/quartz-scheduler-example/

/**
* Scheduler Task --- This class is the one which contains the task that needs to be executed...
* */
public class RunMeTask
{
    public void printMe() {
        System.out.println("Run Me ~");
    }
}

/**
* Scheduler Job --- This class is the one which implements the Job interface
*/

import java.util.Map;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;

public class RunMeJob implements Job
{

    public RunMeJob() {
    }
    public void execute(JobExecutionContext context)
    throws JobExecutionException {

        Map dataMap = context.getJobDetail().getJobDataMap();
        RunMeTask task = (RunMeTask)dataMap.get("runMeTask");
        task.printMe();
    }
}

/**
*
* Scheduler Job --- This class is the one which implements the Job interface to work with the Cron trigger
*/

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;

public class CronJob implements Job
{

    public CronJob() {
    }
    public void execute(JobExecutionContext context)
    throws JobExecutionException {

                  System.out.println("inside the cron job methoid------>>");
    }
}

/**
*
* This class is the one which will initiate the trigger and schedule the job

import java.text.ParseException;
import java.util.Date;
import java.util.Map;
import org.quartz.CronTrigger;

import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SimpleTrigger;
import org.quartz.impl.StdSchedulerFactory;

public class CronLearning {
public static void main( String[] args ) throws Exception
    {
      simpleTrig();
      unixCronTrig();

    }

private static void simpleTrig() throws SchedulerException{
        RunMeTask task = new RunMeTask();

        //specify your sceduler task details
        JobDetail job = new JobDetail();

        job.setName("runMeJob");
        job.setJobClass(RunMeJob.class);

        Map dataMap = job.getJobDataMap();
        dataMap.put("runMeTask", task);

        //configure the scheduler time
        SimpleTrigger trigger = new SimpleTrigger();
        trigger.setName("runMeJobTesting");
        trigger.setStartTime(new Date(System.currentTimeMillis() + 1000));
        //trigger.setRepeatCount(SimpleTrigger.REPEAT_INDEFINITELY);
        trigger.setRepeatCount(2);
        trigger.setRepeatInterval(30000);
//trigger.setEndTime(new Date(System.currentTimeMillis() + 60000));
        //schedule it
        Scheduler scheduler = new StdSchedulerFactory().getScheduler();
        scheduler.start();
        scheduler.scheduleJob(job, trigger);
}
private static void unixCronTrig() throws SchedulerException, ParseException{
        RunMeTask task = new RunMeTask();

        //specify your sceduler task details
        JobDetail job = new JobDetail();

        job.setName("CronJob");
        job.setJobClass(CronJob.class);

        CronTrigger trigger = new CronTrigger();
        trigger.setName("CronJobTesting");
//configure the scheduler time to fire every 30 seconds
        //trigger.setCronExpression("0/30 * * * * ?");
//configure the scheduler time to fire once
        trigger.setCronExpression("10 05 07 25 6 ? 2012");
        //schedule it
        Scheduler scheduler = new StdSchedulerFactory().getScheduler();
        scheduler.start();
        scheduler.scheduleJob(job, trigger);

        System.out.println("cron expression --->"+trigger.getCronExpression());
}
}

Shared Objects

noreply@blogger.com (Rambros) — Thu, 14 Jun 2012 12:50:00 +0000

Hi All,

I was working in my application and i gotta use the concept of cookies. Then i though of using Flex Shared objects. I just ran through the sites to find the difference between cookies and shared object, this is what the site says,

A browser cookie is a "small piece of text stored on a user's computer by a web browser. A cookie consists of one or more name-value pairs containing bits of information".

A web application uses cookies for session management, personalization and tracking. Most browsers restrict the size of a cookie to 4 kb.

In a Flex application, storing data on a user's computer for later use is accomplished using Local Shared Objects rather than cookies. A Local Shared Object can store up to 100 kb of data without asking permission of the user. Unlike cookies that are capable of storing only text values, Local Shared Objects can store many data types including Number, String, Boolean, XML, Date, Array & Object.

A simple Example for using shared object is as follows,

<mx:Application xmlns:mx="http://www.adobe.com/2006/mxml" layout="absolute">
<mx:Script>
    <![CDATA[
        import mx.controls.Alert;
    var ob:SharedObject;
        private function setobj():void{
            ob= SharedObject.getLocal("setobj1");
            if(ob.size>0){
                Alert.show("shared object from --->"+ob.data.mydata);
                if(ob.data.mydata==undefined){
                    ob.data.mydata="test==="
                }
            }
            else{
                ob.data.mydata="test==="
            }
        }

    ]]>
</mx:Script>
    <mx:Button click="setobj()" label="click me" width="100" height="100" x="50" y="50" />

</mx:Application>

Following are the links where you can find the useful information and API information.

http://livedocs.adobe.com/flex/3/html/help.html?content=lsos_5.html

http://livedocs.adobe.com/flex/3/html/help.html?content=lsos_3.html

http://blog.flexdevelopers.com/2010/01/flex-basics-local-shared-object.html

Memcache

noreply@blogger.com (Rambros) — Tue, 12 Jun 2012 11:32:00 +0000

Hi All,

I came across a interesting caching mechanism, it is quite simple to use and understand. Spymemcached is used for this purpose. You can refer the site http://sacharya.com/using-memcached-with-java/ for full details.

To work with it you will require a memcache s/w and a couple of library files.

Memcache server can be downloaded from : http://memcached.org/

Libraries(jars) : http://code.google.com/p/spymemcached/downloads/detail?name=memcached-2.6rc1.jar&can=4&q=

There are many method's in the package but we will be mainly using three methods only and they are set(key,expirytime,value),get(key),delete(key).

A sample java code snippet to understand memcache usage is as follows.

void whatIsMemcache() {
        try {
            //127.0.0.1 - machine's ip
            //11211 - port in which memcache server running
            MemcachedClient c = new MemcachedClient(new InetSocketAddress("127.0.0.1", 11211));
            String s = "Raghu";
            c.set("someKey", 30, s);

            Object myObject = c.get("someKey");
            System.out.println("myobject---->" + myObject.toString());
            c.delete("someKey");

        } catch (IOException ex) {
            ex.printStackTrace();
        }
    }

Types of Joins

noreply@blogger.com (Rambros) — Mon, 21 May 2012 07:01:00 +0000

Hello Everyone,

Today i was working to prepare some notes for my team with respect to Database and i wanted to share the same with you all. The notes is about usages of join in the query.

CROSS JOIN :-

The result is cartessian product of two tables, i.e, Table A* Table B number of rows.

select * from company cross join employee
select * from company,employee

INNER JOIN OR EQUI JOIN :-

This is the type of join where tables are combined based on a common column.

select * from company,employee where company.id=employee.companyid

select * from company inner join employee on company.id=employee.companyid

OUTER JOIN:-

Join is used to combine all rows of one table with matching rows from the other table and also show unmatchable records from other table. It is used whenever multiple tables must be accessed through a SQL SELECT statement

Left Outer Join:-

The below Query return you the set of records or rows from table compnay matches with table employee. The table also display the set of records from left table that do not matches with the right table. The unmatchable records are displayed with null values.

select * from company left join employee on company.id=emlpoyee.companyid

Right Outer Join:-

This join return rows that have matching data in the right table

select * from company right join employee on company.id=employee.companyid

FULL JOIN :-

The Full Join return you the combine result set of both table and return a null value for missing matches on both side of the table. For example, this will helps you to see each records from company who is in employee,but also help you to see each records from company which is not a part of a employee. and each employee which does not have an company. The UNION clause returns the results of two SQL queries into a single result set table..

select * from company left join employee on company.id=employee.companyid union select * from company right join employee on company.id=employee.companyid

NATURAL JOIN :-

Natural Join is a specialization of equi-joins. The join compares all columns in both tables that have the same column-name in both tables that have column name in the joined table. The resulting set include only one column for each pair of the same named column

select * from company natural left join employee

Colours in combobox dataprovider

noreply@blogger.com (Rambros) — Mon, 07 May 2012 10:19:00 +0000

Dear All,

I came across a post in the internet which i thought it will be useful for beginners. This post is about using item renderer in combo box and display the list items in different colur.

CustomCombobox.mxml

<?xml version="1.0" encoding="utf-8"?>
<mx:Application xmlns:mx="http://www.adobe.com/2006/mxml"
                layout="absolute"
                creationComplete="init();">
    <mx:Script>
        <![CDATA[
            import mx.collections.ArrayCollection;
            [Bindable]
            private var popcmb:ArrayCollection=new ArrayCollection();

            private function init():void
            {
                popcmb.addItem({label: "Value1", data: 100});
                popcmb.addItem({label: "Value2", data: 200});
                popcmb.addItem({label: "Value3", data: 300});
                popcmb.addItem({label: "Value4", data: 400});
                popcmb.addItem({label: "Value5", data: 500});
            }
        ]]>
    </mx:Script>
    <mx:Panel x="180"
            y="79"
            width="533"
            height="305"
            layout="absolute"
            title="Custom ComboBox"
            borderColor="#70A7FA">
        <mx:ComboBox id="cmb"
                    x="152"
                    y="70"
                    width="150" dataProvider="{popcmb}"
                    height="30" itemRenderer="LabelComp">
        </mx:ComboBox>
    </mx:Panel>

</mx:Application>
------------------------------------------------------------------------------------------------

LabelComp.mxml

<?xml version="1.0" encoding="utf-8"?>
<mx:HBox xmlns:mx="http://www.adobe.com/2006/mxml" width="100%" height="100%">
    <mx:Label text="{data.label}">

    </mx:Label>
    <mx:Script>
        <![CDATA[
            override public function set data(value:Object):void{
                super.data = value;
                if(value && value.data){
                    if(value.data<400){
                        setStyle("color","#FF0000");
                    }
                    else{
                        setStyle("color","#00FF00");
                    }
                }
                else{
                    setStyle("color","#000000");
                }
                    super.invalidateDisplayList();
            }
        ]]>
    </mx:Script>
</mx:HBox>

Courtesy : Internet

DB Versioning

noreply@blogger.com (Rambros) — Tue, 13 Dec 2011 10:58:00 +0000

If you deploy version 2.0 of your application against version 1.0 of your database, what do you get? A broken application, that's what. That's why your database should always be under source control, right next to your application code. You deploy the app, and you deploy the database.

When it comes to version control, the database is often a second or even third-class citizen. Version control for source code is used by most development teams today. It gives you a history of all the changes you made, you can use it to share your code with others and you can work on an experimental feature without polluting the stable product. These are just some of the reasons why version control software is considered indispensable today. But where does our database fit in all this? How can we share the changes we want to make to the database with our colleagues, and eventually with our production environment?

Database version control is something that most developers have to deal with regularly, yet only a few have actually thought about what solution might be best for them. Most people have a solution that sort of works for them, but when you ask them about the subject they are pretty convinced that there must be some better way to manage database changes, they're just not entirely sure what that solution is – but the silver bullet must be out there somewhere, right?

Writing your own script

A common starting point is to have a custom script to apply database patches (sometimes also called "deltas" or "migrations") to your database. This approach is widely used and works quite well for a lot of people. The idea behind this approach is simple: we store patch files in a directory in our project. These patch files are checked into version control alongside our source code.

whenever a developer makes a change to the database schema they must add the SQL patch file to this directory describing the change. The patch file is then checked in to version control together with the source code. When anyone updates a copy of the code, they will receive patch files as well as source code changes, and these patches need to be applied to the database to bring it to the version expected by the code.

In order to automate this using a script, our script basically needs to do two things

Run database patches on the database

Remember which one we executed last, so next time we know which ones to execute

To keep track of which patch file we executed last, we could simply update a value in our database, first checking the current patch level and then running any later scripts.

This approach works well and is much better than making manual or undocumented database changes. We could create a simple script that updates our project from source control and then runs any patches automatically, and use this to update our projects on both development and production platforms.

As simple as this solution might look, similar solutions work quite well for many applications and these make a great starting point for implementing database version control in your own projects

Rollback

Of course you hope to never get into this situation, but sometimes you might want roll back a production update. This can for example happen when the application was insufficiently tested, or when the application behaves or performs differently on the production machines than expected. Rolling back your source code is usually quite simple: you can just change the symlink to the directory containing the previous version, or use your version control software to update the code base to an earlier revision. For databases though, reverting is a bit more complicated.

One possible approach is to maintain undo files. This would be a file that does exactly the opposite of what your patch file did, and can be used to revert an update whenever something went wrong.

Bear in mind though that some database operations are not reversible and in those situations this approach is less useful. Imagine a patch file that drops a column from a table and an undo file that creates the column again. Yes, your database schema would now be the same again, but the contents of the column are gone.

One of the main things I found out about database version control is that different projects require different approaches, and while I do not make use of undo files myself, other people rely on them and use them very frequently. Consider the options; does your project require rollback scripts? If you think so, include these in your process. They might one day save your life (or at least your deployment).

Where Is My Silver Bullet?

You might think that there would be a better solution, to compare databases and synchronise any differences between them, for example. However, if you imagine for a moment that you want to create a tool to do just that. It all works fine when adding or removing stuff, but it gets tricky when renaming tables or columns. The tool would not be able to tell whether a column was renamed, or a column was dropped and another column was added (warning: the existing tools that do compare databases always go for the "drop and add" solution if you renamed something). Since such a tool wouldn't be able to tell the difference it would have to guess, and therefore may not work correctly in all situations.

So database version control is not as simple as making two schemas equal to each other; it is about remembering all changes you did in development and then repeating exactly those steps at all other locations. Exactly how you document those steps is not really important. So far we have used SQL, but as we will see later on, other tools use languages like XML or even PHP. No matter what language you use, you will always have to document all the steps you did, in order to repeat exactly those steps somewhere else. Documenting those steps is the part that developers consider to be cumbersome and painful, but it is absolutely required if you want to do database version control in a reliable way.

Courtesy : Internet

Overloading in Flex

noreply@blogger.com (Rambros) — Fri, 29 Jul 2011 10:10:00 +0000

Dear folks ,
One important question thats been asked by most of the interviewer is overloading in flex. Flex Does not support Overloading . If we want to make use of those functionality then some work around has to be done . Following example will illustrate the reason

<mx:Application xmlns:mx="http://www.adobe.com/2006/mxml" layout="absolute">
    <mx:Script>
        <![CDATA[
            import mx.controls.Alert;

            private function overloadtest():void
            {
                Alert.show("No argument method overload");
            }

// the following method is a overloaded method , at compile time this method will show error "Duplicate function overloading."
            private function overloadtest(e:String):void
            {
                Alert.show("single argument method overload --- " + e);
            }
        ]]>
    </mx:Script>
    <mx:Button x="111" y="188" label="type1" click="overloadtest();"/>
    <mx:Button x="333" y="188" label="type2" click="overloadtest('type2');"/>

</mx:Application>

This behavior maybe is because Action Script follows the ECMA Script standard. A function is indeed one property of the object, so, like you CAN'T have two properties with the same name, you CAN'T have two functions with the same name. (This is just a hypothesis)

when you declare a function like

function Identifier(arg0, arg1) {
    // body
}

It created a variable object with name Identifier and value equals to function object like the this new Function(arg0,arg1,body) . So we cannot have the more than one property for the current variable object with the same name .

Courtesy :
Internet

Tooltip next to the Column in Datagrid

noreply@blogger.com (Rambros) — Fri, 24 Jun 2011 12:45:00 +0000

Hi All , In datagrid the tooltip will be displayed over the values .In order to show the tooltip at the right or without hiding the original value in the grid we shall use item renderer concept. Here is a simple example of that.

<mx:DataGrid width="99%" rowCount="10" id="queueList" itemClick="getid(event)" dataProvider="{planListValue.children()}" draggableColumns="false" styleName="DataGridStyle" left="5"
                            top="4" right="5">
                    <mx:columns>
                        <mx:Array>
                            <mx:DataGridColumn headerText="Item Name" dataField="@itemname" showDataTips="true">
                                <mx:itemRenderer>
                                    <mx:Component>
                                        <mx:Label>
                                            <mx:Script>
                                                <![CDATA[
                                                    import mx.controls.Alert;

                                                    override public function set data(value:Object):void
                                                    {
                                                        super.data=value;
                                                        this.toolTip=value.@itemname;
                                                        this.selectable=true;
                                                        super.invalidateDisplayList();
                                                    }
                                                ]]>
                                            </mx:Script>
                                        </mx:Label>
                                    </mx:Component>
                                </mx:itemRenderer>
                            </mx:DataGridColumn>
                            <mx:DataGridColumn headerText="Type" dataField="@type" showDataTips="true" width="100">
                                <mx:itemRenderer>
                                    <mx:Component>
                                        <mx:Label>
                                            <mx:Script>
                                                <![CDATA[
                                                    import mx.controls.Alert;

                                                    override public function set data(value:Object):void
                                                    {
                                                        super.data=value;
                                                        this.toolTip=value.@type;
                                                        this.selectable=true;
                                                        super.invalidateDisplayList();
                                                    }
                                                ]]>
                                            </mx:Script>
                                        </mx:Label>
                                    </mx:Component>
                                </mx:itemRenderer>
                            </mx:DataGridColumn>
                            <mx:DataGridColumn headerText="Plan" dataField="@planname" width="100" showDataTips="true">
                                <mx:itemRenderer>
                                    <mx:Component>
                                        <mx:Label>
                                            <mx:Script>
                                                <![CDATA[
                                                    import mx.controls.Alert;

                                                    override public function set data(value:Object):void
                                                    {
                                                        super.data=value;
                                                        this.toolTip=value.@planname;
                                                        this.selectable=true;
                                                        super.invalidateDisplayList();
                                                    }
                                                ]]>
                                            </mx:Script>
                                        </mx:Label>
                                    </mx:Component>
                                </mx:itemRenderer>
                            </mx:DataGridColumn>
                            <mx:DataGridColumn headerText="Generation Date" width="150" dataField="@generationdate" headerWordWrap="true" showDataTips="true">
                                <mx:itemRenderer>
                                    <mx:Component>
                                        <mx:Label>
                                            <mx:Script>
                                                <![CDATA[
                                                    import mx.controls.Alert;

                                                    override public function set data(value:Object):void
                                                    {
                                                        super.data=value;
                                                        this.toolTip=value.@generationdate;
                                                        this.selectable=true;
                                                        super.invalidateDisplayList();
                                                    }
                                                ]]>
                                            </mx:Script>
                                        </mx:Label>
                                    </mx:Component>
                                </mx:itemRenderer>
                            </mx:DataGridColumn>
                            <mx:DataGridColumn headerText="Last Printed" dataField="@lastPrinted" showDataTips="true">
                                <mx:itemRenderer>
                                    <mx:Component>
                                        <mx:Label>
                                            <mx:Script>
                                                <![CDATA[
                                                    import mx.controls.Alert;

                                                    override public function set data(value:Object):void
                                                    {
                                                        super.data=value;
                                                        this.toolTip=value.@lastPrinted;
                                                        this.selectable=true;
                                                        super.invalidateDisplayList();
                                                    }
                                                ]]>
                                            </mx:Script>
                                        </mx:Label>
                                    </mx:Component>
                                </mx:itemRenderer>
                            </mx:DataGridColumn>
                            <mx:DataGridColumn headerText="Item Id" dataField="@itemid" visible="false" showDataTips="true">
                                <mx:itemRenderer>
                                    <mx:Component>
                                        <mx:Label>
                                            <mx:Script>
                                                <![CDATA[
                                                    import mx.controls.Alert;

                                                    override public function set data(value:Object):void
                                                    {
                                                        super.data=value;
                                                        this.toolTip=value.@itemid;
                                                        this.selectable=true;
                                                        super.invalidateDisplayList();
                                                    }
                                                ]]>
                                            </mx:Script>
                                        </mx:Label>
                                    </mx:Component>
                                </mx:itemRenderer>
                            </mx:DataGridColumn>
                            <mx:DataGridColumn headerText="plantype" dataField="@plantype" visible="false" showDataTips="true">
                                <mx:itemRenderer>
                                    <mx:Component>
                                        <mx:Label>
                                            <mx:Script>
                                                <![CDATA[
                                                    import mx.controls.Alert;

                                                    override public function set data(value:Object):void
                                                    {
                                                        super.data=value;
                                                        this.toolTip=value.@plantype;
                                                        this.selectable=true;
                                                        super.invalidateDisplayList();
                                                    }
                                                ]]>
                                            </mx:Script>
                                        </mx:Label>
                                    </mx:Component>
                                </mx:itemRenderer>
                            </mx:DataGridColumn>
                            <mx:DataGridColumn headerText="cron" dataField="@cronid" visible="false" showDataTips="true">
                                <mx:itemRenderer>
                                    <mx:Component>
                                        <mx:Label>
                                            <mx:Script>
                                                <![CDATA[
                                                    import mx.controls.Alert;

                                                    override public function set data(value:Object):void
                                                    {
                                                        super.data=value;
                                                        this.toolTip=value.@cronid;
                                                        this.selectable=true;
                                                        super.invalidateDisplayList();
                                                    }
                                                ]]>
                                            </mx:Script>
                                        </mx:Label>
                                    </mx:Component>
                                </mx:itemRenderer>
                            </mx:DataGridColumn>
                        </mx:Array>
                    </mx:columns>
                </mx:DataGrid>

Usages of Enum in Java

noreply@blogger.com (Rambros) — Fri, 03 Jun 2011 09:20:00 +0000

How an Enum will look like ,

public enum Suit { clubs, diamonds, hearts, spades }

Enum has various advantages :

Compile-time type safety.
Performance comparable to int constants.
Type system provides a namespace for each enum type, so you don't have to prefix each constant name.
Typesafe constants aren't compiled into clients, so you can add, reorder or even remove constants without the need to recompile clients. (If you remove a constant that a client is using, you'll fail fast with an informative error message.)
Printed values are informative. (Which would you rather see in a stack trace: "Indigo" or "6?")
Enum constants can be used in collections (e.g., as HashMap keys).
You can add arbitrary fields and methods to an enum class.
An enum type can be made to implement arbitrary interfaces.

Additionally, the facility rectifies the two major shortcomings of the Typesafe Enum pattern:

The proposed construct is simple and readable. (The Typesafe Enum pattern described in "Effective Java" involves a large amount of boilerplate code, which obscures programmer intent, deters all but the most determined programmers from using the pattern, and provides opportunities to introduce errors.)
The proposed construct can be used with switch statements.

The enum declaration is a special kind of class declaration. An enum type has public, self-typed members for each of the named enum constants. All enum classes have high-quality toString, hashCode, andequals methods. All are Serializable, Comparable and effectively final. None are Cloneable. All of the "Object methods" except toString are final: we take care of comparison and serialization, and ensure that it's done right.
Arbitrary fields may be added to enum classes, and to individual enum constants. The ability to add such fields will only be used by relatively sophisticated programmers, but greatly enhances the power of the facility. It adds nothing to the complexity of the facility for programmers who don't need the extra power.

Courtesy : Internet

Flex Custom Components and Custom Events in action

noreply@blogger.com (Rambros) — Thu, 12 May 2011 06:12:00 +0000

Hi All ,
I would like to share few custom components and custom events and overriding a existing components classes in a simple way.

Following is the mxml application which makes use of the custom components and events.

<mx:Application xmlns:mx="http://www.adobe.com/2006/mxml" layout="absolute" xmlns:ns1="com.*">
    <ns1:MyButton x="310" y="97" width="104" height="44" label="My Button" enableChanged="testMyEvent(event);" />

    <mx:Script>
        <![CDATA[
            import mx.managers.PopUpManager;
            import mx.controls.Label;
            import com.MyDataEvent;
            import com.TestData;
            import mx.controls.Alert;
            import com.MyEvent;


            private function testMyEvent(e:MyEvent):void{
                //Alert.show("inside my event");
                var dc:TestData=new TestData();
                dc.testString="test label";
                dc.text=dc.testString;

                mycan.addChild(dc);
                gotoMethod();

            }
            private function gotoMethod():void{
                var c:comp=new comp();
                c.addEventListener("listen",listenSuccess);
                PopUpManager.addPopUp(c,this,false);
                PopUpManager.centerPopUp(c);
                /*
            dispatchEvent(new MyDataEvent("listen","Hello from raghu"));
            var l:Label=new Label();
            l.x="60";
            l.y="100";
            mycan.addChild(l);*/

            }
            private function listenSuccess(e:MyDataEvent):void{
                Alert.show(e.myData);
            }
        ]]>
    </mx:Script>
    <mx:Canvas id="mycan" backgroundColor="#ffffff" x="320" y="233" width="200" height="200">
        <mx:Button x="39" y="133" label="Button" click="gotoMethod();"/>
    </mx:Canvas>


</mx:Application>

Following are the custom components and custom events.

comp.mxml ::::

<mx:Canvas xmlns:mx="http://www.adobe.com/2006/mxml" width="400" height="300">
    <mx:Button x="167" y="54" label="Button" click="dis()"/>
    <mx:Script>
        <![CDATA[
            import mx.controls.Alert;
            import mx.managers.PopUpManager;
            import com.MyDataEvent;
            private function dis():void{
                try{
                dispatchEvent(new MyDataEvent("listen","Hello from raghu"));
                PopUpManager.removePopUp(this);}
                catch(e:Error){
                    Alert.show(e.message);
                }
            }
        ]]>
    </mx:Script>
</mx:Canvas>

TestData.as ::::

package com
{
    import mx.controls.Label;

    public dynamic class TestData extends Label
    {
        public function TestData()
        {
            super();
        }

    }
}

MyEvent.as ::::

package com
{
    import flash.events.Event;

    public class MyEvent extends Event
    {
        public function MyEvent(type:String,isEnabled:Boolean=false)
        {
            super(type);
            this.isEnabled = isEnabled;
        }
        // Define static constant.
        public static const ENABLE_CHANGED:String = "enableChanged";

        // Define a public variable to hold the state of the enable property.
        public var isEnabled:Boolean;

        // Override the inherited clone() method.
        override public function clone():Event {
            return new MyEvent(type, isEnabled);
        }
    }
}

MyButton.as ::::

package com
{
    import flash.events.Event;
    import flash.events.MouseEvent;

    import mx.controls.Button;

    [Event(name="enableChanged", type="com.MyEvent")]
    public class MyButton extends Button
    {
        public function MyButton()
        {
            super();
            addEventListener(MouseEvent.CLICK, dispatchMyEvent);

            addEventListener(MyEvent.ENABLE_CHANGED, enableChanged1);
        }

        private function dispatchMyEvent(e:Event):void
        {
            dispatchEvent(new MyEvent("enableChanged"));
        }

        private function enableChanged1(e:Event):void
        {
            //dispatchEvent(new MyEvent("enableChanged"));
        }

    }
}

MyDataEvent.as ::::

package com
{
    import flash.events.Event;

    public dynamic class MyDataEvent extends Event
    {
        public function MyDataEvent(type:String, data:String="")
        {
            super(type, data);
            myData=data;
        }
        public var myData:String="";

        override public function clone():Event
        {
            return new MyDataEvent(type, myData);
        }

    }
}

Timezone Example

noreply@blogger.com (Rambros) — Mon, 04 Apr 2011 09:01:00 +0000

This example will illustrate how to convert current GMT time to any specified Timezone.

import java.sql.Timestamp;
import java.text.DateFormat;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Calendar;
import java.util.Date;
import java.util.GregorianCalendar;
import java.util.SimpleTimeZone;
import java.util.TimeZone;
import java.util.logging.Level;
import java.util.logging.Logger;

public class Testtimezone {
   private static void timeConversionFromGMT(String zone) {
   SimpleDateFormat dateFormat = new SimpleDateFormat("dd.MMM.yyyy HH:mm:ss a");
   Date sysDate = new Date();

   SimpleTimeZone localTimeZone = new SimpleTimeZone(sysDate.getTimezoneOffset(), "GMT");
   Calendar calendar = Calendar.getInstance(localTimeZone);
   calendar.setTime(sysDate);
   System.out.println(" re current time : " + dateFormat.format(calendar.getTime()));
   //String[] zones = TimeZone.getAvailableIDs();
   //for (String zone : zones) {
   calendar.setTimeZone(TimeZone.getTimeZone(zone));
   TimeZone currTimezone = calendar.getTimeZone();
   long currentOffset = calendar.get(Calendar.ZONE_OFFSET);
   if (currTimezone.inDaylightTime(new Date(calendar.getTimeInMillis()))) {
   currentOffset = currentOffset + calendar.get(Calendar.DST_OFFSET);
   }
   Date date = new Timestamp(calendar.getTimeInMillis() + currentOffset);
   System.out.println("zone name : " + zone + " current time : " + dateFormat.format(date));
   //System.out.println();
   System.out.println("--------------"+date.getTime());
   //}
   }
   public static void main(String[] args) {
   try {
   timeConversionFromGMT("IST");
   Calendar calendar = new GregorianCalendar();
   Date date = calendar.getTime();
   DateFormat localFormat = DateFormat.getDateInstance();
   //Fri Oct 16 14:48:45 IST 2009 EEE MMM d HH:mm:ss z yyyy MM/dd/yyyy K:mm:ss a
   DateFormat format3 = new SimpleDateFormat("EEE MMM d HH:mm:ss z yyyy");
   // TimeZone istTime = TimeZone.getTimeZone("IST");
   //format3.setTimeZone(istTime);
   Date d = format3.parse("Tue Nov 17 22:50:58 GMT+05:30 2009");

   System.out.println(d.toString());
   System.out.println(date.toString());
   // System.out.println("hjghjg" + date.toString());
   //calendar.setTimeZone("");
   TimeZone tim=calendar.getTimeZone();
   System.out.println("timezone -- "+tim.getDisplayName());
   } catch (ParseException ex) {
   Logger.getLogger(Testtimezone.class.getName()).log(Level.SEVERE, null, ex);
   }
   }
}

Sorting HashMap with different Scenarios

noreply@blogger.com (Rambros) — Wed, 16 Feb 2011 12:04:00 +0000

This code snippet will explain the hashmap functionality and its sorting feature.

import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.SortedSet;
import java.util.TreeSet;

public class SortingHash {

   static Map myMap = new HashMap();
   static HashMap map = new LinkedHashMap();

   /**
   * setting values for hashmap
   */
   static void sethash() {
   myMap.put("E", 5);
   myMap.put("B", 2);
   myMap.put("A", 1);
   myMap.put("D", 4);
   myMap.put("C", 3);

   }

   public static void main(String a[]) {
   sethash();
   sortKey();
   sortValue();
   }

   /**
   * Sorting hashmap with key
   */
   static void sortKey() {
   SortedSet<String> sortedset = new TreeSet<String>(myMap.keySet());

   Iterator<String> it = sortedset.iterator();

   while (it.hasNext()) {
   System.out.println(it.next());
   }
   }

   /**
   * Sorting hashmap with value
   */
   static void sortValue() {
   List yourMapKeys = new ArrayList(myMap.keySet());
   List yourMapValues = new ArrayList(myMap.values());
   TreeSet sortedSet = new TreeSet(yourMapValues);
   Object[] sortedArray = sortedSet.toArray();
   int size = sortedArray.length;
   System.out.println("---------------");
   for (int i = 0; i < size; i++) {
   System.out.println((Integer) sortedArray[i]);
   }
   for (int i = 0; i < size; i++) {
   map.put(yourMapKeys.get(yourMapValues.indexOf(sortedArray[i])),
   sortedArray[i]);
   }
   Set ref = map.keySet();
   Iterator it = ref.iterator();
   System.out.println("---------------");
   while (it.hasNext()) {

   System.out.println((String) it.next());
   }
   }


}

simple overriding concept (regular mistake)

noreply@blogger.com (Rambros) — Wed, 16 Feb 2011 11:09:00 +0000

I have presented a sample code snippet which will explain overriding mechanism and the common mistake that we do.

public class RegularOverridingMistake extends base {

   int i=100;
   public static void main(String a[]){
   base b=new RegularOverridingMistake();
   System.out.println("b.i--"+b.i);
   b.dip();
   }
   @Override
   void dip(){
   System.out.println("inside RegularOverridingMistake");
   }
}
class base{
   int i=5;
   base(){
   // dip(); uncomment this line and look out the error
   }
   void dip(){
   System.out.println("inside base class");
   }
}