Laboratoire ICAR » Plateforme TXM

      <command

            defaultHandler="org.txm.searchengine.cqp.rcp.handlers.base.Substraction"

            id="org.txm.searchengine.cqp.rcp.handlers.base.Substraction"

            name="Substraction">

      </command>

      <command

            defaultHandler="org.txm.searchengine.cqp.rcp.handlers.base.Union"

            id="org.txm.searchengine.cqp.rcp.handlers.base.Union"

            name="Union">

      </command>

      <command

            defaultHandler="org.txm.searchengine.cqp.rcp.handlers.base.Intersection"

            id="org.txm.searchengine.cqp.rcp.handlers.base.Intersection"

            name="Intersection">

      </command>

         <command

               commandId="org.txm.searchengine.cqp.rcp.handlers.base.Substraction"

               label="MINUS"

               style="push">

            <visibleWhen

                  checkEnabled="false">

               <reference

                     definitionId="OneSubCorpusSelected">

               </reference>

            </visibleWhen>

         </command>

         <command

               commandId="org.txm.searchengine.cqp.rcp.handlers.base.Intersection"

               label="INTER"

               style="push">

            <visibleWhen

                  checkEnabled="false">

               <reference

                     definitionId="OneSubCorpusSelected">

               </reference>

            </visibleWhen>

         </command>

         <command

               commandId="org.txm.searchengine.cqp.rcp.handlers.base.Union"

               label="UNION"

               style="push">

            <visibleWhen

                  checkEnabled="false">

               <reference

                     definitionId="OneSubCorpusSelected">

               </reference>

            </visibleWhen>

         </command>

package org.txm.searchengine.cqp.rcp.dialogs;

import java.util.Arrays;

import java.util.HashMap;

import java.util.List;

import org.eclipse.jface.dialogs.Dialog;

import org.eclipse.jface.viewers.CellLabelProvider;

import org.eclipse.jface.viewers.ISelectionChangedListener;

import org.eclipse.jface.viewers.IStructuredSelection;

import org.eclipse.jface.viewers.ITreeContentProvider;

import org.eclipse.jface.viewers.SelectionChangedEvent;

import org.eclipse.jface.viewers.TreeNode;

import org.eclipse.jface.viewers.TreeNodeContentProvider;

import org.eclipse.jface.viewers.TreeViewer;

import org.eclipse.jface.viewers.TreeViewerColumn;

import org.eclipse.jface.viewers.Viewer;

import org.eclipse.jface.viewers.ViewerCell;

import org.eclipse.osgi.util.NLS;

import org.eclipse.swt.SWT;

import org.eclipse.swt.events.SelectionEvent;

import org.eclipse.swt.events.SelectionListener;

import org.eclipse.swt.layout.GridData;

import org.eclipse.swt.layout.GridLayout;

import org.eclipse.swt.widgets.Button;

import org.eclipse.swt.widgets.Composite;

import org.eclipse.swt.widgets.Control;

import org.eclipse.swt.widgets.Label;

import org.eclipse.swt.widgets.Shell;

import org.eclipse.swt.widgets.Spinner;

import org.eclipse.swt.widgets.Text;

import org.eclipse.swt.widgets.ToolBar;

import org.txm.core.results.TXMResult;

import org.txm.rcp.editors.TXMEditor;

import org.txm.rcp.swt.GLComposite;

import org.txm.rcp.swt.provider.SimpleLabelProvider;

import org.txm.searchengine.cqp.corpus.CQPCorpus;

import org.txm.searchengine.cqp.corpus.Subcorpus;

/**

 * 

 * 

 *

 */

public class SetOperationsDialog extends Dialog {

	private Text textField;

	String operation;

	CQPCorpus corpus[] = new CQPCorpus[2];

	String name;

//	private Label corpus1Label;

//	private Label corpus2Label;

	private String previousDefaultName;

private TreeViewer treeViewer;

//	private Label questionLabel;

private TreeViewerColumn nameColumn;

	public static HashMap<String, String> operations = new HashMap<String, String>();

	static {

		operations.put("UNION", "''{0}'' subcorpus union with...");

		operations.put("INTER", "''{0}'' subcorpus intersection with...");

		operations.put("MINUS", "''{0}'' subcorpus minus");

		operations.put("COMPL", "''{0}'' subcorpus complement...");

	}

	public static HashMap<String, String> symbols = new HashMap<String, String>();

	static {

		symbols.put("UNION", "{0} ∪ {1}");

		symbols.put("INTER", "{0} ∩ {1}");

		symbols.put("MINUS", "{0} - {1}");

		symbols.put("COMPL", "-{0}");

	}

	/**

	 * 

	 * @param parentShell

	 * @param title

	 * @param question

	 * @param text

	 */

	public SetOperationsDialog(Shell parentShell, String operation, CQPCorpus corpus1) {

		super(parentShell);

		this.operation = operation;

		this.corpus[0] = corpus1;

		if (this.operation.equals("COMPL")) {

			this.corpus[1] = corpus1.getCorpusParent();

		}

	}

	@Override

	protected void configureShell(Shell newShell) {

		super.configureShell(newShell);

		newShell.setText(NLS.bind(operations.get(operation), corpus[0].getName()));

		newShell.setMinimumSize(400, 200);

	}

	@Override

	protected Control createDialogArea(Composite parent) {

		Composite comp = (Composite) super.createDialogArea(parent);

		GridLayout layout = (GridLayout) comp.getLayout();

		layout.numColumns = 2;

		Label l = new Label(comp, SWT.LEFT);

		l.setText("Name");

		l.setLayoutData(new GridData(GridData.BEGINNING, GridData.CENTER, false, false));

		textField = new Text(comp, SWT.SINGLE|SWT.BORDER);

		textField.setLayoutData(new GridData(GridData.FILL, GridData.CENTER, true, false));

		treeViewer = new TreeViewer (comp, SWT.SINGLE | SWT.BORDER);

		if (this.operation.equals("COMPL")) {

			treeViewer.getTree().setEnabled(false);

		}

		treeViewer.setContentProvider(new ITreeContentProvider() {

			@Override

			public void inputChanged(Viewer viewer, Object oldInput, Object newInput) { }

			@Override

			public void dispose() { }

			@Override

			public boolean hasChildren(Object element) {

				if (element instanceof CQPCorpus) {

					return ((CQPCorpus)element).getSubcorpora().size() > 0;

				}

				return false;

			}

			@Override

			public Object getParent(Object element) {

				if (element instanceof CQPCorpus) {

					return ((CQPCorpus)element).getParent();

				}

				return null;

			}

			@SuppressWarnings("rawtypes")

			@Override

			public Object[] getElements(Object inputElement) {

				if (inputElement == null) return new Object[0];

				if (inputElement instanceof CQPCorpus) {

					return ((CQPCorpus)inputElement).getSubcorpora().toArray();

				}

				return null;

			}

			@Override

			public Object[] getChildren(Object element) {

				if (element instanceof CQPCorpus) {

					return ((CQPCorpus)element).getSubcorpora().toArray();

				} 

				return new Object[0];

			}

		});

		treeViewer.getTree().setLayoutData(new GridData(GridData.FILL, GridData.FILL, true, true, 2 , 1));

		treeViewer.getTree().setHeaderVisible(true);

		treeViewer.getTree().setLinesVisible(true);

		treeViewer.addSelectionChangedListener(new ISelectionChangedListener() {

			@Override

			public void selectionChanged(SelectionChangedEvent event) {

				IStructuredSelection sel = event.getStructuredSelection();

				Object o = sel.getFirstElement();

				corpus[1] = (CQPCorpus) o;

				initializeWidgets();

			}

		});

		nameColumn = new TreeViewerColumn(treeViewer, SWT.NONE);

		nameColumn.getColumn().setText("Availables Subcorpus");

		nameColumn.getColumn().pack();

		nameColumn.setLabelProvider(new CellLabelProvider() {

			@Override

			public void update(ViewerCell cell) {

				Object element = cell.getElement();

				if (element instanceof CQPCorpus) {

					cell.setText(((CQPCorpus)element).getName());

				} else {

					cell.setText("");

				}

			}

		});

		treeViewer.setInput(corpus[0].getMainCorpus());

		initializeWidgets();

		return comp;

	}

	@Override

	protected boolean isResizable() {

	    return true;

	}

	public void initializeWidgets() {

//		corpus1Label.setText(corpus[0].getName());

//		corpus2Label.setText(corpus[1].getName());

//		questionLabel.setText(NLS.bind(symbols.get(operation), corpus[0], corpus[1]));

		//textField.getShell().setText(NLS.bind(symbols.get(operation), corpus[0], corpus[1]));

		String current = textField.getText();

		if (current.length() == 0 || current.equals(previousDefaultName)) {

			textField.setText(getDefaultName());

		}

	}

	public String getDefaultName() {

		String s = "[select a subcorpus in the list]";

		if (corpus[1] != null) {

			s = corpus[1].getName();

		}

		previousDefaultName = NLS.bind(symbols.get(operation), corpus[0].getName(), s);

		return previousDefaultName;

	}

	@Override

	protected void buttonPressed(int buttonId) {

		if (buttonId == Dialog.OK) {

			name = textField.getText();

		}

		super.buttonPressed(buttonId);

	}

	public String getName() {

		return name;

	}

	public CQPCorpus[] getCorpusOrder() {

		return corpus;

	}

}

// Copyright © 2010-2013 ENS de Lyon.

// Copyright © 2007-2010 ENS de Lyon, CNRS, INRP, University of

// Lyon 2, University of Franche-Comté, University of Nice

// Sophia Antipolis, University of Paris 3.

// 

// The TXM platform is free software: you can redistribute it

// and/or modify it under the terms of the GNU General Public

// License as published by the Free Software Foundation,

// either version 2 of the License, or (at your option) any

// later version.

// 

// The TXM platform is distributed in the hope that it will be

// useful, but WITHOUT ANY WARRANTY; without even the implied

// warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR

// PURPOSE. See the GNU General Public License for more

// details.

// 

// You should have received a copy of the GNU General

// Public License along with the TXM platform. If not, see

// http://www.gnu.org/licenses.

// 

// 

// 

// $LastChangedDate:$

// $LastChangedRevision:$

// $LastChangedBy:$ 

//

package org.txm.searchengine.cqp.rcp.handlers.base;

import java.util.Arrays;

import java.util.List;

import org.eclipse.core.commands.AbstractHandler;

import org.eclipse.core.commands.ExecutionEvent;

import org.eclipse.core.commands.ExecutionException;

import org.eclipse.core.runtime.IProgressMonitor;

import org.eclipse.core.runtime.IStatus;

import org.eclipse.core.runtime.Status;

import org.eclipse.jface.viewers.IStructuredSelection;

import org.eclipse.jface.window.Window;

import org.eclipse.osgi.util.NLS;

import org.eclipse.swt.widgets.Shell;

import org.eclipse.ui.handlers.HandlerUtil;

import org.txm.rcp.JobsTimer;

import org.txm.rcp.messages.TXMUIMessages;

import org.txm.rcp.swt.dialog.TextDialog;

import org.txm.rcp.utils.JobHandler;

import org.txm.rcp.views.corpora.CorporaView;

import org.txm.searchengine.cqp.AbstractCqiClient;

import org.txm.searchengine.cqp.CQPSearchEngine;

import org.txm.searchengine.cqp.core.messages.CQPSearchEngineCoreMessages;

import org.txm.searchengine.cqp.corpus.CQPCorpus;

import org.txm.searchengine.cqp.corpus.Subcorpus;

import org.txm.searchengine.cqp.rcp.dialogs.SetOperationsDialog;

import org.txm.utils.logger.Log;

// TODO: Auto-generated Javadoc

/**

 * Command which creates a subcorpus from a Corpus @ author mdecorde.

 */

public class Substraction extends AbstractHandler {

	/** The selection. */

	private IStructuredSelection selection;

	/* (non-Javadoc)

	 * @see org.eclipse.core.commands.AbstractHandler#execute(org.eclipse.core.commands.ExecutionEvent)

	 */

	@Override

	public Object execute(ExecutionEvent event) throws ExecutionException {

		selection = (IStructuredSelection) HandlerUtil.getCurrentSelection(event);

		if (selection == null) {

			System.out.println(TXMUIMessages.noSelectionForColon+HandlerUtil.getActiveWorkbenchWindow(event).getActivePage().getActiveEditor());

			return null;

		}

		List list = selection.toList();

		if (list.size() == 0) {

			Log.info("No corpus selected");

			return null;

		} else if (list.size() != 1) {

			Log.info("Substraction need a selection of 1 corpus");

			return null;

		}

		Object firstElement = list.get(0);

//		Object secondElement = list.get(1);

		if (!(firstElement instanceof CQPCorpus)) {

			System.out.println(TXMUIMessages.selectionIsNotACorpusColon+firstElement);

			return null;

		}

//		if (!(secondElement instanceof CQPCorpus)) {

//			System.out.println(TXMUIMessages.selectionIsNotACorpusColon+secondElement);

//			return null;

//		}

		final CQPCorpus corpus = (CQPCorpus) firstElement;

		corpus.compute(false);

//		final CQPCorpus corpus2 = (CQPCorpus) secondElement;

//		corpus2.compute(false);

		Shell shell = HandlerUtil.getActiveWorkbenchWindowChecked(event).getShell();

		final SetOperationsDialog d = new SetOperationsDialog(shell, "MINUS", corpus);

		int code = d.open();

		if (code == Window.OK) {

			JobHandler jobhandler = new JobHandler(NLS.bind(

					TXMUIMessages.creatingASubcorpusOnP0, corpus.getName())) {

				@Override

				protected IStatus run(IProgressMonitor monitor) {		

					this.runInit(monitor);

					JobsTimer.start();

					try {

						monitor.beginTask(TXMUIMessages.creatingASubcorpusInTheSearchEngine, 100);

						Subcorpus subcorpus = null;

						String name = d.getName();

						if (name.length() == 0) {

							name = d.getDefaultName();

						}

						AbstractCqiClient cqi = CQPSearchEngine.getCqiClient();

						String cqpid = "S"+Subcorpus.getNextSubcorpusCounter();

						CQPCorpus[] order = d.getCorpusOrder();

						order[1].compute(false);

						String query = cqpid+"=difference "+order[0].getQualifiedCqpId()+" "+order[1].getQualifiedCqpId()+";";

						System.out.println("QUERY="+query);

						cqi.query(query);

						subcorpus = corpus.getCorpusParent().createSubcorpus(name, cqpid);

						if (subcorpus == null) {

							monitor.done();

							System.out.println(TXMUIMessages.errorColonSubcorpusWasNotCreated);

							return Status.CANCEL_STATUS;

						}

						System.out.println(NLS.bind(TXMUIMessages.doneColonP0Created, subcorpus.getName()));

						monitor.worked(50);

						monitor.subTask(TXMUIMessages.refreshingCorpora);

						final Subcorpus subcorpus2 = subcorpus; 

						syncExec(new Runnable() {

							@Override

							public void run() {

								CorporaView.refresh();

								CorporaView.expand(subcorpus2.getParent());

							}

						});

						monitor.worked(100);

					} catch (ThreadDeath td) {

						return Status.CANCEL_STATUS;

					} catch (Exception e) {

						org.txm.utils.logger.Log.printStackTrace(e);

						Log.severe(e.toString());

						try {

							System.out.println(NLS.bind(CQPSearchEngineCoreMessages.lastCQPErrorColon, CQPSearchEngine.getCqiClient().getLastCQPError()));

						} catch (Exception e1) {

							System.out.println(TXMUIMessages.failedToGetLastCQPErrorColon+e1);

							org.txm.utils.logger.Log.printStackTrace(e1);

						}

					} finally {

						monitor.done();

						JobsTimer.stopAndPrint();

					}				

					return Status.OK_STATUS;

				}

			};

			jobhandler.startJob();

		}

		return null;

	}

}

// Copyright © 2010-2013 ENS de Lyon.

// Copyright © 2007-2010 ENS de Lyon, CNRS, INRP, University of

// Lyon 2, University of Franche-Comté, University of Nice

// Sophia Antipolis, University of Paris 3.

// 

// The TXM platform is free software: you can redistribute it

// and/or modify it under the terms of the GNU General Public

// License as published by the Free Software Foundation,

// either version 2 of the License, or (at your option) any

// later version.

// 

// The TXM platform is distributed in the hope that it will be

// useful, but WITHOUT ANY WARRANTY; without even the implied

// warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR

// PURPOSE. See the GNU General Public License for more

// details.

// 

// You should have received a copy of the GNU General

// Public License along with the TXM platform. If not, see

// http://www.gnu.org/licenses.

// 

// 

// 

// $LastChangedDate:$

// $LastChangedRevision:$

// $LastChangedBy:$ 

//

package org.txm.searchengine.cqp.rcp.handlers.base;

import java.util.Arrays;

import java.util.List;

import org.eclipse.core.commands.AbstractHandler;

import org.eclipse.core.commands.ExecutionEvent;

import org.eclipse.core.commands.ExecutionException;

import org.eclipse.core.runtime.IProgressMonitor;

import org.eclipse.core.runtime.IStatus;

import org.eclipse.core.runtime.Status;

import org.eclipse.jface.viewers.IStructuredSelection;

import org.eclipse.jface.window.Window;

import org.eclipse.osgi.util.NLS;

import org.eclipse.swt.widgets.Shell;

import org.eclipse.ui.handlers.HandlerUtil;

import org.txm.rcp.JobsTimer;

import org.txm.rcp.messages.TXMUIMessages;

import org.txm.rcp.swt.dialog.TextDialog;

import org.txm.rcp.utils.JobHandler;

import org.txm.rcp.views.corpora.CorporaView;

import org.txm.searchengine.cqp.AbstractCqiClient;

import org.txm.searchengine.cqp.CQPSearchEngine;

import org.txm.searchengine.cqp.core.messages.CQPSearchEngineCoreMessages;

import org.txm.searchengine.cqp.corpus.CQPCorpus;

import org.txm.searchengine.cqp.corpus.Subcorpus;

import org.txm.searchengine.cqp.rcp.dialogs.SetOperationsDialog;

import org.txm.utils.logger.Log;

// TODO: Auto-generated Javadoc

/**

 * Command which creates a subcorpus from a Corpus @ author mdecorde.

 */

public class Intersection extends AbstractHandler {

	/** The selection. */

	private IStructuredSelection selection;

	/* (non-Javadoc)

	 * @see org.eclipse.core.commands.AbstractHandler#execute(org.eclipse.core.commands.ExecutionEvent)

	 */

	@Override

	public Object execute(ExecutionEvent event) throws ExecutionException {

		selection = (IStructuredSelection) HandlerUtil.getCurrentSelection(event);

		if (selection == null) {

			System.out.println(TXMUIMessages.noSelectionForColon+HandlerUtil.getActiveWorkbenchWindow(event).getActivePage().getActiveEditor());

			return null;

		}

		List list = selection.toList();

		if (list.size() == 0) {

			Log.info("No corpus selected");

			return null;

		} else if (list.size() != 1) {

			Log.info("Substraction need a selection of 1 corpus");

			return null;

		}

		Object firstElement = list.get(0);

//		Object secondElement = list.get(1);

		if (!(firstElement instanceof CQPCorpus)) {

			System.out.println(TXMUIMessages.selectionIsNotACorpusColon+firstElement);

			return null;

		}

//		if (!(secondElement instanceof CQPCorpus)) {

//			System.out.println(TXMUIMessages.selectionIsNotACorpusColon+secondElement);

//			return null;

//		}

		final CQPCorpus corpus = (CQPCorpus) firstElement;

		corpus.compute(false);

//		final CQPCorpus corpus2 = (CQPCorpus) secondElement;

//		corpus2.compute(false);

		Shell shell = HandlerUtil.getActiveWorkbenchWindowChecked(event).getShell();

		final SetOperationsDialog d = new SetOperationsDialog(shell, "INTER", corpus);

		int code = d.open();

		if (code == Window.OK) {

			JobHandler jobhandler = new JobHandler(NLS.bind(

					TXMUIMessages.creatingASubcorpusOnP0, corpus.getName())) {

				@Override

				protected IStatus run(IProgressMonitor monitor) {		

					this.runInit(monitor);

					JobsTimer.start();

					try {

						monitor.beginTask(TXMUIMessages.creatingASubcorpusInTheSearchEngine, 100);

						Subcorpus subcorpus = null;

						String name = d.getName();

						if (name.length() == 0) {

							name = d.getDefaultName();

						}

						AbstractCqiClient cqi = CQPSearchEngine.getCqiClient();

						String cqpid = "S"+Subcorpus.getNextSubcorpusCounter();

						CQPCorpus[] order = d.getCorpusOrder();

						order[1].compute(false);

						String query = cqpid+"=intersect "+order[0].getQualifiedCqpId()+" "+order[1].getQualifiedCqpId()+";";

						System.out.println("QUERY="+query);

						cqi.query(query);

						subcorpus = corpus.getCorpusParent().createSubcorpus(name, cqpid);

						if (subcorpus == null) {

							monitor.done();

							System.out.println(TXMUIMessages.errorColonSubcorpusWasNotCreated);

							return Status.CANCEL_STATUS;

						}

						System.out.println(NLS.bind(TXMUIMessages.doneColonP0Created, subcorpus.getName()));

						monitor.worked(50);

						monitor.subTask(TXMUIMessages.refreshingCorpora);

						final Subcorpus subcorpus2 = subcorpus; 

						syncExec(new Runnable() {

							@Override

							public void run() {

								CorporaView.refresh();

								CorporaView.expand(subcorpus2.getParent());

							}

						});

						monitor.worked(100);

					} catch (ThreadDeath td) {

						return Status.CANCEL_STATUS;

					} catch (Exception e) {

						org.txm.utils.logger.Log.printStackTrace(e);

						Log.severe(e.toString());

						try {

							System.out.println(NLS.bind(CQPSearchEngineCoreMessages.lastCQPErrorColon, CQPSearchEngine.getCqiClient().getLastCQPError()));

						} catch (Exception e1) {

							System.out.println(TXMUIMessages.failedToGetLastCQPErrorColon+e1);

							org.txm.utils.logger.Log.printStackTrace(e1);

						}

					} finally {

						monitor.done();

						JobsTimer.stopAndPrint();

					}				

					return Status.OK_STATUS;

				}

			};

			jobhandler.startJob();

		}

		return null;

	}

}

// Copyright © 2010-2013 ENS de Lyon.

// Copyright © 2007-2010 ENS de Lyon, CNRS, INRP, University of

// Lyon 2, University of Franche-Comté, University of Nice

// Sophia Antipolis, University of Paris 3.

// 

// The TXM platform is free software: you can redistribute it

// and/or modify it under the terms of the GNU General Public

// License as published by the Free Software Foundation,

// either version 2 of the License, or (at your option) any

// later version.

// 

// The TXM platform is distributed in the hope that it will be

// useful, but WITHOUT ANY WARRANTY; without even the implied

// warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR

// PURPOSE. See the GNU General Public License for more

// details.

// 

// You should have received a copy of the GNU General

// Public License along with the TXM platform. If not, see

// http://www.gnu.org/licenses.

// 

// 

// 

// $LastChangedDate:$

// $LastChangedRevision:$

// $LastChangedBy:$ 

//

package org.txm.searchengine.cqp.rcp.handlers.base;

import java.util.Arrays;

import java.util.List;

import org.eclipse.core.commands.AbstractHandler;

import org.eclipse.core.commands.ExecutionEvent;

import org.eclipse.core.commands.ExecutionException;

import org.eclipse.core.runtime.IProgressMonitor;

import org.eclipse.core.runtime.IStatus;

import org.eclipse.core.runtime.Status;

import org.eclipse.jface.viewers.IStructuredSelection;

import org.eclipse.jface.window.Window;

import org.eclipse.osgi.util.NLS;

import org.eclipse.swt.widgets.Shell;

import org.eclipse.ui.handlers.HandlerUtil;

import org.txm.rcp.JobsTimer;

import org.txm.rcp.messages.TXMUIMessages;

import org.txm.rcp.swt.dialog.TextDialog;

import org.txm.rcp.utils.JobHandler;

import org.txm.rcp.views.corpora.CorporaView;

import org.txm.searchengine.cqp.AbstractCqiClient;

import org.txm.searchengine.cqp.CQPSearchEngine;

import org.txm.searchengine.cqp.core.messages.CQPSearchEngineCoreMessages;

import org.txm.searchengine.cqp.corpus.CQPCorpus;

import org.txm.searchengine.cqp.corpus.Subcorpus;

import org.txm.searchengine.cqp.rcp.dialogs.SetOperationsDialog;

import org.txm.utils.logger.Log;

// TODO: Auto-generated Javadoc

/**

 * Command which creates a subcorpus from a Corpus @ author mdecorde.

 */

public class Union extends AbstractHandler {

	/** The selection. */

	private IStructuredSelection selection;

	/* (non-Javadoc)

	 * @see org.eclipse.core.commands.AbstractHandler#execute(org.eclipse.core.commands.ExecutionEvent)

	 */

	@Override

	public Object execute(ExecutionEvent event) throws ExecutionException {

		selection = (IStructuredSelection) HandlerUtil.getCurrentSelection(event);

		if (selection == null) {

			System.out.println(TXMUIMessages.noSelectionForColon+HandlerUtil.getActiveWorkbenchWindow(event).getActivePage().getActiveEditor());

			return null;

		}

		List list = selection.toList();

		if (list.size() == 0) {

			Log.info("No corpus selected");

			return null;

		} else if (list.size() != 1) {

			Log.info("Substraction need a selection of 1 corpus");

			return null;

		}

		Object firstElement = list.get(0);

//		Object secondElement = list.get(1);

		if (!(firstElement instanceof CQPCorpus)) {

			System.out.println(TXMUIMessages.selectionIsNotACorpusColon+firstElement);

			return null;

		}

//		if (!(secondElement instanceof CQPCorpus)) {

//			System.out.println(TXMUIMessages.selectionIsNotACorpusColon+secondElement);

//			return null;

//		}

		final CQPCorpus corpus = (CQPCorpus) firstElement;

		corpus.compute(false);

//		final CQPCorpus corpus2 = (CQPCorpus) secondElement;

//		corpus2.compute(false);

		Shell shell = HandlerUtil.getActiveWorkbenchWindowChecked(event).getShell();

		final SetOperationsDialog d = new SetOperationsDialog(shell, "UNION", corpus);

		int code = d.open();

		if (code == Window.OK) {

			JobHandler jobhandler = new JobHandler(NLS.bind(

					TXMUIMessages.creatingASubcorpusOnP0, corpus.getName())) {

				@Override

				protected IStatus run(IProgressMonitor monitor) {		

					this.runInit(monitor);

					JobsTimer.start();

					try {

						monitor.beginTask(TXMUIMessages.creatingASubcorpusInTheSearchEngine, 100);

						Subcorpus subcorpus = null;

						String name = d.getName();

						if (name.length() == 0) {

							name = d.getDefaultName();

						}

						AbstractCqiClient cqi = CQPSearchEngine.getCqiClient();

						String cqpid = "S"+Subcorpus.getNextSubcorpusCounter();

						CQPCorpus[] order = d.getCorpusOrder();

						order[1].compute(false);

						String query = cqpid+"=join "+order[0].getQualifiedCqpId()+" "+order[1].getQualifiedCqpId()+";";

						System.out.println("QUERY="+query);

						cqi.query(query);

						subcorpus = corpus.getCorpusParent().createSubcorpus(name, cqpid);

						if (subcorpus == null) {

							monitor.done();

							System.out.println(TXMUIMessages.errorColonSubcorpusWasNotCreated);

							return Status.CANCEL_STATUS;

						}

						System.out.println(NLS.bind(TXMUIMessages.doneColonP0Created, subcorpus.getName()));

						monitor.worked(50);

						monitor.subTask(TXMUIMessages.refreshingCorpora);

						final Subcorpus subcorpus2 = subcorpus; 

						syncExec(new Runnable() {

							@Override

							public void run() {

								CorporaView.refresh();

								CorporaView.expand(subcorpus2.getParent());

							}

						});

						monitor.worked(100);

					} catch (ThreadDeath td) {

						return Status.CANCEL_STATUS;

					} catch (Exception e) {

						org.txm.utils.logger.Log.printStackTrace(e);

						Log.severe(e.toString());

						try {

							System.out.println(NLS.bind(CQPSearchEngineCoreMessages.lastCQPErrorColon, CQPSearchEngine.getCqiClient().getLastCQPError()));

						} catch (Exception e1) {

							System.out.println(TXMUIMessages.failedToGetLastCQPErrorColon+e1);

							org.txm.utils.logger.Log.printStackTrace(e1);

						}

					} finally {

						monitor.done();

						JobsTimer.stopAndPrint();

					}				

					return Status.OK_STATUS;

				}

			};

			jobhandler.startJob();

		}

		return null;

	}

}

Export-Package: org.txm.importer.cwb,

 org.txm.searchengine.cqp,

 org.txm.searchengine.cqp.clientExceptions,

 org.txm.searchengine.cqp.core.functions.preview,

 org.txm.searchengine.cqp.core.functions.selection,

 org.txm.searchengine.cqp.core.functions.summary,

 org.txm.searchengine.cqp.core.messages,

 org.txm.searchengine.cqp.core.tests,

 org.txm.searchengine.cqp.corpus,

 org.txm.searchengine.cqp.corpus.query,

 org.txm.searchengine.cqp.serverException

import java.io.File;

import java.util.UUID;

	/** The size in token */

	/** The number of starting text. */

	protected int nbtext = -1;

	protected int[] textEndLimits;

	/** The textids. */

	protected HashMap<String, Integer> textids = null;

	/**

	 * 

	 * @return the text_id values of the CQP corpus ordered by position

	 * @throws CqiClientException

	 * @throws IOException

	 * @throws CqiServerError

	 */

	abstract public String[] getCorpusTextIdsList() throws CqiClientException, IOException, CqiServerError;

	/**

	 * Gets the nb texts.

	 *

	 * @return the nb texts

	 * @throws CqiClientException the cqi client exception

	 * @throws CqiServerError 

	 * @throws IOException 

	 */

	abstract public int getNbTexts() throws CqiClientException, IOException, CqiServerError;

	/**

	 * Return the CQP END positions of the main corpus texts

	 */

	abstract public int[] getTextEndLimits() throws CqiClientException, IOException, CqiServerError, InvalidCqpIdException;

	/**

	 * Gets the texts ids and order number in corpus.

	 *

	 * @return the texts ids

	 * @throws IOException Signals that an I/O exception has occurred.

	 * @throws CqiServerError the cqi server error

	 * @throws CqiClientException the cqi client exception

	 */

	abstract public HashMap<String, Integer>  getTextsIds() throws IOException, CqiServerError, CqiClientException;

	/**

	 * Return the CQP START positions of the main corpus texts

	 */

	/**

	 * Return the CQP START positions of the main corpus texts

	 */

	public int[] getTextStartLimits() throws CqiClientException, IOException, CqiServerError, InvalidCqpIdException {

		if (textLimits == null) {

			textLimits = getStartLimits("<text>[]");

		}

		return textLimits;

	}

	/**

	 * Return the CQP END positions of the main corpus texts

	 */

	public int[] getTextEndLimits() throws CqiClientException, IOException, CqiServerError, InvalidCqpIdException {

		if (textEndLimits == null) {

			String queryResultId = queryResultNamePrefix + UUID.randomUUID().toString();

			CorpusManager.getCorpusManager().getCqiClient().cqpQuery(

					this.getQualifiedCqpId(), queryResultId, "<text>[] expand to text"); //$NON-NLS-1$

			QueryResult queryResult = new QueryResult(queryResultId, queryResultId, this,	new CQLQuery("<text>[] expand to text")); //$NON-NLS-1$

			textEndLimits = queryResult.getEnds();

		}

		return textEndLimits;

	}

	/**

	 * Gets the nb texts.

	 *

	 * @return the nb texts

	 * @throws CqiClientException the cqi client exception

	 * @throws CqiServerError 

	 * @throws IOException 

	 */

	public int getNbTexts() throws CqiClientException, IOException, CqiServerError

	{

		if (nbtext == -1) {

			StructuralUnit text_su = this.getStructuralUnit("text"); //$NON-NLS-1$

			StructuralUnitProperty text_id_sup = text_su.getProperty("id"); //$NON-NLS-1$

			nbtext = CorpusManager.getCorpusManager().getCqiClient().attributeSize(text_id_sup.getQualifiedName());

		}

		return nbtext;

	}

	/**

	 * 

	 * @return the text_id values of the CQP corpus ordered by position

	 * @throws CqiClientException

	 * @throws IOException

	 * @throws CqiServerError

	 */

	public String[] getCorpusTextIdsList() throws CqiClientException, IOException, CqiServerError {

		int nbtext = getNbTexts();

		int[] structs = new int[nbtext];

		for(int i = 0 ; i < nbtext ; i++)

			structs[i] = i;

		StructuralUnit text_su = this.getStructuralUnit("text"); //$NON-NLS-1$

		StructuralUnitProperty text_id_sup = text_su.getProperty("id"); //$NON-NLS-1$

		return CorpusManager.getCorpusManager().getCqiClient().struc2Str(text_id_sup.getQualifiedName(), structs);

	}

	/**

	 * Gets the texts ids and order number in corpus.

	 *

	 * @return the texts ids

	 * @throws IOException Signals that an I/O exception has occurred.

	 * @throws CqiServerError the cqi server error

	 * @throws CqiClientException the cqi client exception

	 */

	public HashMap<String, Integer>  getTextsIds() throws IOException, CqiServerError, CqiClientException

	{

		if (textids == null) {

			textids = new HashMap<String, Integer>();

			int nbtext = getNbTexts();

			int[] structs = new int[nbtext];

			for(int i = 0 ; i < nbtext ; i++)

				structs[i] = i;

			StructuralUnit text_su = this.getStructuralUnit("text"); //$NON-NLS-1$

			StructuralUnitProperty text_id_sup = text_su.getProperty("id"); //$NON-NLS-1$

			String[] ids = CorpusManager.getCorpusManager().getCqiClient().struc2Str(text_id_sup.getQualifiedName(), structs);

			for(int i = 0 ; i < ids.length ; i++)

			{

				textids.put(ids[i], structs[i]);

			}

		}

		return textids;

	}

import java.util.HashMap;

import java.util.UUID;

	/**

	 * Return the CQP START positions of the main corpus texts

	 */

	public int[] getTextStartLimits() throws CqiClientException, IOException, CqiServerError, InvalidCqpIdException {

		if (textLimits == null) {

			textLimits = getStartLimits("[text] expand left to text");

		}

		return textLimits;

	}

	/**

	 * Return the CQP END positions of the main corpus texts

	 */

	public int[] getTextEndLimits() throws CqiClientException, IOException, CqiServerError, InvalidCqpIdException {

		if (textEndLimits == null) {

			String queryResultId = queryResultNamePrefix + UUID.randomUUID().toString();

			CorpusManager.getCorpusManager().getCqiClient().cqpQuery(

					this.getQualifiedCqpId(), queryResultId, "[text] expand right to text"); //$NON-NLS-1$

			QueryResult queryResult = new QueryResult(queryResultId, queryResultId, this,	new CQLQuery("[text] expand right to text")); //$NON-NLS-1$

			textEndLimits = queryResult.getEnds();

		}

		return textEndLimits;

	}

	/**

	 * Gets the nb texts.

	 *

	 * @return the nb texts

	 * @throws CqiClientException the cqi client exception

	 * @throws CqiServerError 

	 * @throws IOException 

	 */

	public int getNbTexts() throws CqiClientException, IOException, CqiServerError

	{

		if (nbtext == -1) {

			List<Integer> structsIncorpus = getTextNumberInCorpus();

			nbtext = structsIncorpus.size();

		}

		return nbtext;

	}

	private List<Integer> getTextNumberInCorpus() throws CqiClientException, IOException, CqiServerError {

		StructuralUnit text_su = this.getStructuralUnit("text"); //$NON-NLS-1$

		StructuralUnitProperty text_id_sup = text_su.getProperty("id"); //$NON-NLS-1$

		nbtext = CorpusManager.getCorpusManager().getCqiClient().attributeSize(text_id_sup.getQualifiedName());

		int[] structs = new int[nbtext];

		int[][] structs_positions = new int[structs.length][2];

		for (int i = 0 ; i < nbtext ; i++) {

			structs[i] = i;

			structs_positions[i] = CorpusManager.getCorpusManager().getCqiClient().struc2Cpos(text_id_sup.getQualifiedName(), i);

		}

		List<Integer> structsIncorpus = new ArrayList<Integer>();

		//filter structs with matches

		List<Match> matches = this.getMatches();

		int iText = 0;

		int iMatch = 0;

		nbtext = 0;

		while (iText < structs.length && iMatch < matches.size()) {

			if (structs_positions[iText][1] < matches.get(iMatch).getStart()) { // match before text

				iText++;

			} else if (matches.get(iMatch).getEnd() < structs_positions[iText][0]) { // text before match

				iMatch++;

			} else { // a match in the text

				structsIncorpus.add(iText);

				iText++;

			}

		}

		return structsIncorpus;

	}

	/**

	 * 

	 * @return the text_id values of the CQP corpus ordered by position

	 * @throws CqiClientException

	 * @throws IOException

	 * @throws CqiServerError

	 */

	public String[] getCorpusTextIdsList() throws CqiClientException, IOException, CqiServerError {

		StructuralUnit text_su = this.getStructuralUnit("text"); //$NON-NLS-1$

		StructuralUnitProperty text_id_sup = text_su.getProperty("id"); //$NON-NLS-1$

		List<Integer> list = getTextNumberInCorpus();

		int[] structs = new int[list.size()];

		for (int i = 0 ; i < list.size() ; i++) {

			structs[i] = list.get(i);

		}

		return CorpusManager.getCorpusManager().getCqiClient().struc2Str(text_id_sup.getQualifiedName(), structs);

	}

	/**

	 * Gets the texts ids and order number in corpus.

	 *

	 * @return the texts ids

	 * @throws IOException Signals that an I/O exception has occurred.

	 * @throws CqiServerError the cqi server error

	 * @throws CqiClientException the cqi client exception

	 */

	public HashMap<String, Integer>  getTextsIds() throws IOException, CqiServerError, CqiClientException

	{

		if (textids == null) {

			textids = new HashMap<String, Integer>();

			List<Integer> list = getTextNumberInCorpus();

			int[] structs = new int[list.size()];

			for (int i = 0 ; i < list.size() ; i++) {

				structs[i] = list.get(i);

			}

			StructuralUnit text_su = this.getStructuralUnit("text"); //$NON-NLS-1$

			StructuralUnitProperty text_id_sup = text_su.getProperty("id"); //$NON-NLS-1$

			String[] ids = CorpusManager.getCorpusManager().getCqiClient().struc2Str(text_id_sup.getQualifiedName(), structs);

			for(int i = 0 ; i < ids.length ; i++) {

				textids.put(ids[i], structs[i]);

			}

		}

		return textids;

	}