/*
 *                 Sun Public License Notice
 *
 * The contents of this file are subject to the Sun Public License
 * Version 1.0 (the "License"). You may not use this file except in
 * compliance with the License. A copy of the License is available at
 * http://www.sun.com/
 *
 * The Original Code is NetBeans. The Initial Developer of the Original
 * Code is Sun Microsystems, Inc. Portions Copyright 1997-2004 Sun
 * Microsystems, Inc. All Rights Reserved.
 */

package org.netbeans.modules.db.explorer.actions;

import java.beans.PropertyChangeEvent;
import java.beans.PropertyChangeListener;
import java.beans.PropertyChangeSupport;
import java.sql.DatabaseMetaData;
import java.sql.SQLException;
import java.text.MessageFormat;

import org.openide.DialogDisplayer;
import org.openide.NotifyDescriptor;
import org.openide.nodes.Node;
import org.openide.util.RequestProcessor;

import org.netbeans.modules.db.explorer.dataview.DataViewWindow;
import org.netbeans.modules.db.explorer.infos.ColumnNodeInfo;
import org.netbeans.modules.db.explorer.infos.DatabaseNodeInfo;
import org.netbeans.modules.db.explorer.infos.TableNodeInfo;
import org.netbeans.modules.db.explorer.infos.ViewColumnNodeInfo;
import org.netbeans.modules.db.explorer.infos.ViewNodeInfo;

public class ViewDataAction extends DatabaseAction {
    static final long serialVersionUID =-894644054833609687L;

    private String quoteStr;

    /** The support to fire property change */
    final private PropertyChangeSupport propertySupport;
    
    private Node[] nodes;
    private DataViewWindow win;
    
    public ViewDataAction() {
        propertySupport = new PropertyChangeSupport(this);
        propertySupport.addPropertyChangeListener(new PropertyChangeListener() {
            public void propertyChange(PropertyChangeEvent evt) {
                if (evt.getPropertyName().equals("retrieved")) //NOI18N
                    finishAction();
            }
        });
    }
    
    protected boolean enable(Node[] activatedNodes) {
        if (activatedNodes != null)
            if (activatedNodes.length == 1)
                return true;
            else if (activatedNodes.length > 0) {
                int t = 0;
                int v = 0;
                for (int i = 0; i < activatedNodes.length; i++) {
                    if (activatedNodes[i].getCookie(ColumnNodeInfo.class) != null) {
                        t++;
                        continue;
                    }
                    if (activatedNodes[i].getCookie(ViewColumnNodeInfo.class) != null)
                        v++;
                }
                if (t != activatedNodes.length && v != activatedNodes.length)
                    return false;
                else
                    return true;
            } else
                return false;
        else
            return false;
    }

    public void performAction (Node[] activatedNodes) {
        if (activatedNodes != null && activatedNodes.length > 0) {
            nodes = activatedNodes;
            final DatabaseNodeInfo info = (DatabaseNodeInfo) activatedNodes[0].getCookie(DatabaseNodeInfo.class);
            
            //This code needs to run in AWT thread
            try {
                win = new DataViewWindow(info, null);
                win.open();
                win.requestActive();
            } catch (SQLException exc) {
                //PENDING
            }
            
            RequestProcessor.getDefault().post(new Runnable() {
                public void run () {
                    try {
                        DatabaseMetaData dmd = info.getConnection().getMetaData();
                        quoteStr = dmd.getIdentifierQuoteString();
                        if (quoteStr == null)
                            quoteStr = ""; //NOI18N
                        else
                            quoteStr.trim();

                        propertySupport.firePropertyChange("retrieved", null, null); //NOI18N
                    } catch (SQLException exc) {
                        //PENDING
                    }
                }
            }, 0);
        }
    }
        
    private void finishAction() {        
        String expression = ""; //NOI18N
        StringBuffer cols = new StringBuffer();
        Node node;

        try {
            node = nodes[0];
            DatabaseNodeInfo info = (DatabaseNodeInfo) node.getCookie(DatabaseNodeInfo.class);

            String schema = info.getSchema();
            if (schema == null)
                schema = ""; //NOI18N
            else
                schema = schema.trim();

            String onome;
            if (info instanceof TableNodeInfo || info instanceof ViewNodeInfo) {
                onome = quote(info.getName());
                if (!schema.equals("")) //NOI18N
                    onome = quote(schema) + "." + onome; //NOI18N

                expression = "select * from " + onome; //NOI18N
            } else if (info instanceof ColumnNodeInfo || info instanceof ViewColumnNodeInfo) {
                onome = quote((info instanceof ViewColumnNodeInfo) ? info.getView() : info.getTable());
                if (!schema.equals("")) //NOI18N
                    onome = quote(schema) + "." + onome; //NOI18N

                for (int i = 0; i < nodes.length; i++) {
                    node = nodes[i];
                    info = (DatabaseNodeInfo) node.getCookie(DatabaseNodeInfo.class);
                    if (info instanceof ColumnNodeInfo || info instanceof ViewColumnNodeInfo) {
                        if (cols.length() > 0)
                            cols.append(", "); //NOI18N
                        cols.append(quote(info.getName()));
                    }
                }

                expression = "select " + cols.toString() + " from " + onome; //NOI18N
            }

            win.setCommand(expression);
            final DataViewWindow w = win ;
            
            RequestProcessor.getDefault().post(new Runnable() {
                public void run () {
                    w.executeCommand();
                }
            }, 0);
        } catch(Exception exc) {
            String message = MessageFormat.format(bundle.getString("ShowDataError"), new String[] {exc.getMessage()}); // NOI18N
            DialogDisplayer.getDefault().notify(new NotifyDescriptor.Message(message, NotifyDescriptor.ERROR_MESSAGE));
        }
    }

    private String quote(String name) {
        return quoteStr + name + quoteStr;
    }
}