Rss Feeds to XML using database values

main class to create XML file.

Jar files required : commons-digester-rss.jar,  mysql-connector-java-5.0.8.jar

package sri;

import java.io.FileOutputStream;
import java.io.IOException;
import java.text.SimpleDateFormat;
import java.util.Date;

import org.apache.commons.digester.rss.Channel;
import org.apache.commons.digester.rss.Item;

public class RssFeeds
{

    public void RssXml() throws Exception{
  
    RssImpl rImpl = new RssImpl();
    RssBean rBean = new RssBean();
  
    String title = "ItemTitle1";
  
    rBean = rImpl.getRssData(title);
  
    Channel newChannel = new Channel();

    newChannel.setCopyright(rBean.getCpyRight());
    newChannel.setDescription(rBean.getDesc());
    newChannel.setLink(rBean.getChannLink());
    newChannel.setLanguage(rBean.getLang());
    SimpleDateFormat formatter = new SimpleDateFormat("dd MMM yyyy HH:mm:ss Z");
    String today = formatter.format(rBean.getPubDate());
    newChannel.setPubDate(today);

    Item item = new Item();
    item.setTitle(rBean.getItemTitle());
    item.setLink(rBean.getItemLink());
    item.setDescription(rBean.getItemDesc());
    newChannel.setPubDate(today);
    newChannel.addItem(item);

    try
    {
        FileOutputStream fout = new FileOutputStream("C:/feed.xml");
        newChannel.render(fout);
        fout.close();
    }
    catch (IOException e)
    {
        e.printStackTrace();
    }
    }
  
    public static void main(String args[]) throws Exception {
    RssFeeds rss = new RssFeeds();
    rss.RssXml();
    }
}



using hibernates to access data from database.

package sri;

import org.hibernate.Criteria;
import org.hibernate.Query;
import org.hibernate.Session;
import org.hibernate.criterion.Restrictions;

public class RssImpl
{
    Session session = null;

    public RssBean getRssData(String title)throws Exception
    {
    session = HibernateUtil.currentSession();

    RssBean rssBean = new RssBean();
    Criteria crit = session.createCriteria(RssBean.class);
    crit.add(Restrictions.eq("itemTitle", title));
    if(crit.list().size()>0)
        rssBean = (RssBean) crit.list().get(0);
   
    /*String hql = "FROM RssBean as rBean WHERE rbean.itemTitle ='"+ title +"'";
    Query query = session.createQuery(hql);
    if(query.list().size()>0)
        rssBean = (RssBean) query.list().get(0);*/

    return rssBean;

    }

}


create a bean class:

package sri;

import java.io.Serializable;
import java.sql.Timestamp;

public class RssBean implements Serializable{
   
    private String cpyRight;
        private String itemTitle;
    private String desc;
    private String channLink;
    private String lang;
    private Timestamp pubDate;
    private String itemLink;
    private String itemDesc;
   
    public String getCpyRight()
    {
        return cpyRight;
    }
    public void setCpyRight(String cpyRight)
    {
        this.cpyRight = cpyRight;
    }
    public String getItemTitle()
    {
        return itemTitle;
    }
    public void setItemTitle(String itemTitle)
    {
        this.itemTitle = itemTitle;
    }
    public String getDesc()
    {
        return desc;
    }
    public void setDesc(String desc)
    {
        this.desc = desc;
    }
    public String getChannLink()
    {
        return channLink;
    }
    public void setChannLink(String channLink)
    {
        this.channLink = channLink;
    }
    public String getLang()
    {
        return lang;
    }
    public void setLang(String lang)
    {
        this.lang = lang;
    }
    public Timestamp getPubDate()
    {
        return pubDate;
    }
    public void setPubDate(Timestamp pubDate)
    {
        this.pubDate = pubDate;
    }
    public String getItemLink()
    {
        return itemLink;
    }
    public void setItemLink(String itemLink)
    {
        this.itemLink = itemLink;
    }
    public String getItemDesc()
    {
        return itemDesc;
    }
    public void setItemDesc(String itemDesc)
    {
        this.itemDesc = itemDesc;
    }
}

Hibernate util: save as Hibernateutil.java

package sri;

import org.hibernate.HibernateException;
import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.Transaction;
import org.hibernate.cfg.Configuration;
import org.hibernate.engine.SessionFactoryImplementor;


public class HibernateUtil {

    private static SessionFactory sessionFactory;
    private static String schema;

    static {
    try {
        Configuration configuration = new Configuration();
        configuration.configure("hibernate.cfg.xml");
        sessionFactory = configuration.buildSessionFactory();
        SessionFactoryImplementor sessionImpl = (SessionFactoryImplementor) sessionFactory;
        schema = sessionImpl.getSettings().getDefaultSchemaName();
    } catch (Throwable ex) {
        ex.printStackTrace();
        throw new ExceptionInInitializerError(ex);
    }
    }

    private static final ThreadLocal<Session> localSession = new ThreadLocal<Session>();

    /**
     * Create CurrentSession when session not open
     */
    public static Session currentSession() {
    Session s = (Session) localSession.get();

    if (s == null) {
        s = createSession();
    }

    if (!s.isOpen() || !s.isConnected()) {
        localSession.set(null);
        s = null;
        s = createSession();
    }

    if(s.isDirty()){
        if(s.getTransaction().isActive())
        s.getTransaction().rollback();
        s.flush();
        s.close();
        s = null;
        localSession.set(null);
        s = createSession();
    }
    return s;
    }

    /**
     * Create Session
     * @return Session
     */
    private static Session createSession() {
    Session s = sessionFactory.openSession();
    localSession.set(s);
    return s;
    }

    /**
     * Close Session
     * @throws HibernateException
     */
    public static void closeSession() throws HibernateException {
    Session session = localSession.get();
    if (session != null && session.isOpen()) {
        if(session.getTransaction().isActive()) {
        session.getTransaction().rollback();
        }
        session.close();
        localSession.set(null);
    }
    }

    /**
     * Fetch the SessionFactory
     */
    public static SessionFactory getSessionFactory() {
    return sessionFactory;
    }

    /**
     * Flush the Session
     * @throws HibernateException
     */
    public static void flushSession() throws HibernateException {
    Session session = localSession.get();
    if (session != null) {
        session.flush();
    }
    }

    /**
     * Close SessionFactory
     */
    public static void shutdown() {
    getSessionFactory().close();
    }

    /**
     * Save or Update the object and close the session
     */
    public static Object saveOrUpdate(Object obj) {

    Session session = null;
    try {
        session = HibernateUtil.currentSession();
        Transaction transaction = session.beginTransaction();
        transaction.begin();
        session.saveOrUpdate(obj);
        transaction.commit();
        closeSession();
    }catch(HibernateException ex) {
    }
    return obj;
    }

    /**
     * Fetch the Schema
     */
    public static String getDefaultSchema() {
    return schema;
    }

}

hbm.xml file to map the data from the database:: save as -- RssBean.hbm.xml

<?xml version="1.0" encoding="UTF-8"?>

<!DOCTYPE hibernate-mapping PUBLIC "-//Hibernate/Hibernate Mapping DTD 3.0//EN"
          "http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd">
<hibernate-mapping>
    <class name="sri.RssBean" table="rssfeeddata">
        <id column="TITLE" name="itemTitle" type="java.lang.String">
        </id>
        <property column="COPYRIGHT" name="cpyRight" type="java.lang.String"/>
        <property column="DESCRIPTION" name="desc" type="java.lang.String"/>   
        <property column="CHANNELLINK" name="channLink" type="java.lang.String"/>
        <property column="LANGUAG" name="lang" type="java.lang.String"/>
        <property column="PUBDATE" name="pubDate" type="java.sql.Timestamp"/>
        <property column="ITEMLINK" name="itemLink" type="java.lang.String"/>
        <property column="ITEMDESCRIPTION" name="itemDesc" type="java.lang.String"/>
    </class>
</hibernate-mapping>

Hibernate configuration file save as : hibernate.cfg.xml


<?xml version='1.0' encoding='utf-8'?>
<!DOCTYPE hibernate-configuration PUBLIC
"-//Hibernate/Hibernate Configuration DTD//EN"
"http://hibernate.sourceforge.net/hibernate-configuration-3.0.dtd">

<hibernate-configuration>
    <session-factory>
        <property name="hibernate.connection.driver_class">com.mysql.jdbc.Driver</property>
        <property name="hibernate.connection.url">jdbc:mysql://localhost/sri</property>
        <property name="hibernate.connection.username">root</property>
        <property name="hibernate.connection.password">root</property>
        <property name="show_sql">true</property>
        <property name="dialect">org.hibernate.dialect.MySQLDialect</property>
        <!-- Mapping files -->
        <mapping resource="hbm/RssBean.hbm.xml" />
    </session-factory>
</hibernate-configuration>