Laboratoire ICAR » Plateforme TXM

import org.txm.rcp.swt.widget.structures.ContextsSubcorpusPanel;

import org.txm.rcp.swt.widget.structures.SimpleSubcorpusPanel;

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

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

import org.txm.searchengine.cqp.corpus.query.Match;

	@Parameter(key = TXMPreferences.QUERY)

	private AssistedChoiceQueryWidget queryWidget;

	Label matchesInfo;

	Text matchStartsEndsInfo;

	Composite assistantPanel;

			}

		};

		nameLabel = new Label(getMainParametersComposite(), SWT.NONE);

		nameLabel.setText(TXMUIMessages.name);

		queryWidget.addKeyListener(computeKeyListener);

		queryWidget.getQueryWidget().addModifyListener(computeKeyListener);

		ArrayList<String> modes = new ArrayList<String>();

		final ArrayList<SelectionListener> listeners = new ArrayList<SelectionListener>();

			@Override

			public void widgetDefaultSelected(SelectionEvent e) {}

		});

		modeGroups.setLayout(new GridLayout(1, true));

		// RESULT AREA

					if (buffer.length() > 0) buffer.append("\t");

					if (prop.equals("form") && startOfSubMatch) buffer.append("[");

					String v = values.get(prefix+prop)[p];

					buffer.append(v);

					if (prop.equals("form") && endOfSubMatch) buffer.append("]");

				}

		String prefix = UDPreferences.getInstance().getProjectPreferenceValue(corpus.getProject(), UDPreferences.UDPREFIX, UDPreferences.getInstance().getString(UDPreferences.UDPREFIX));

		if (pQuery == null || pQuery.getQueryString().length() ==0) {

		} else {

			return pQuery.getQueryString();

		}

	public static Subcorpus getSentenceSubcorpus(CQPCorpus corpus, String prefix) throws CqiClientException, InterruptedException {

		CQLQuery sentencesQuery = new CQLQuery(getUDSCQPQueryString(prefix));

		}

			udSentences.setVisible(false);

		}

		return udSentences;

	}

	 */

	public static String getUDSCQPQueryString(String prefix) {

		String emptyvalue = TBXPreferences.getInstance().getString(TBXPreferences.EMPTY_PROPERTY_VALUE_CODE);

	}

	public String hasAdditionalDetailsForResult(TXMResult result) {

package org.txm.searchengine.cqp;

import org.txm.core.preferences.TXMPreferences;

/**

	 * List of part names.

	 */

	public static final String PART_NAMES = "part_names"; //$NON-NLS-1$

	/**

	 * Gets the instance.

	@Override

	public void initializeDefaultPreferences() {

		super.initializeDefaultPreferences();

	}

}

import org.txm.searchengine.cqp.clientExceptions.InvalidCqpIdException;

import org.txm.searchengine.cqp.core.functions.selection.SelectionResult;

import org.txm.searchengine.cqp.corpus.query.CQLQuery;

import org.txm.searchengine.cqp.corpus.query.SubcorpusCQLQuery;

import org.txm.searchengine.cqp.serverException.CqiServerError;

import org.txm.utils.TXMProgressMonitor;

	 *            the name

	 * @return the subcorpus by name

	 */

		List<Subcorpus> subcorpora = getSubcorpora();

			if (corpus.getSimpleName().equals(name)) {

				return corpus;

			}

import java.util.ArrayList;

import java.util.Arrays;

import java.util.HashMap;

import java.util.LinkedList;

import java.util.List;

import java.util.UUID;

import org.txm.searchengine.core.Selection;

import org.txm.searchengine.core.messages.SearchEngineCoreMessages;

import org.txm.searchengine.cqp.AbstractCqiClient;

import org.txm.searchengine.cqp.CQPSearchEngine;

import org.txm.searchengine.cqp.NetCqiClient;

import org.txm.searchengine.cqp.clientExceptions.CqiClientException;

 * @author jmague

 */

public class Subcorpus extends CQPCorpus {

	/**

	 * Query used to build the corpus.

	 */

	@Parameter(key = TXMPreferences.QUERY)

	protected IQuery pQuery;

	protected Selection qresult;

	protected SelectionResult selectionResult;

	/**

	 * CQP text ids cache

	 */

	protected String[] cqpTextIDS = null;

	/**

	 * 

	 * @param corpus

	public Subcorpus(CQPCorpus corpus) {

		super(corpus);

	}

	/**

	 * 

	 * @param partition

	public Subcorpus(Partition partition) {

		super(partition);

	}

	/**

	 * 

	 * @param result parent result

		this.pQuery = result.getQuery();

		this.setUserName(pQuery.toString());

	}

	/**

	 * 

	 * @param parametersNodePath

	public Subcorpus(String parametersNodePath) {

		super(parametersNodePath);

	}

	/**

	 * Instantiates a new subcorpus.

	 * 

	 */

	@Override

	protected boolean __compute(TXMProgressMonitor monitor) throws Exception {

		if (this.getParent() instanceof QueryBasedTXMResult) { // update the pQuery

			this.pQuery = ((QueryBasedTXMResult)this.getParent()).getQuery();

			this.setName(pQuery.getName());

		}

		if (pID == null || pID.length() == 0) {

			pID = subcorpusNamePrefix + getNextSubcorpusCounter().toString();

		}

		if (this.pQuery != null) {

			this.qresult = null; // reset

			String parent_id = this.getCorpusParent().getQualifiedCqpId();

				Log.warning(NLS.bind("Error: CQL length limit reached ({0}) with {1} length.", CQLQuery.MAX_CQL_LENGTH, pQuery.getQueryString().length())); 

				return false;

			}

			String q = this.pQuery.getQueryString();

			if (q.matches("undump \"[^\"]+\";")) { // undump query

				String path = q.substring(8, q.length() - 2);

					Log.severe(NLS.bind("Error: could not compute subcorpus from the dump file: {0}.", path));

					return false;

				}

			} else if (q.matches("(union|join|intersect|inter|difference|diff) [^ ]+ [^ ]+;")) {

			} else {

			}

			//this.qresult = this.pQuery.getSearchEngine().query(this.getCorpusParent(), this.pQuery, this.getUserName(), true);

			this.qresult = new QueryResult(this.pID, this.getUserName(), this.getCorpusParent(), (CQLQuery) this.pQuery); // getCorpusParent().query(pQuery, this.pID, true);

			//  queryResult = new QueryResult(queryResultId, queryResultName, this, query);

		}

		cqpTextIDS = null; // reset text ids cache

		return qresult != null;

	}

	@Override

	public String getComputingStartMessage() {

		if (this.pQuery == null) {

			return TXMCoreMessages.bind(SearchEngineCoreMessages.info_computingTheP0SubCorpusOfP1CommaQueryP2, this.getSimpleName(), this.getParent().getName(), "<no query>");

		}

		// created with structure, property and value(s)

		if (this.pQuery instanceof SubcorpusCQLQuery) {

			SubcorpusCQLQuery query = (SubcorpusCQLQuery) this.pQuery;

			return TXMCoreMessages.bind(SearchEngineCoreMessages.info_computingTheP0SubCorpusOfP1CommaQueryP2, this.getSimpleName(), this.getParent().getName(), this.getQuery().asString());

		}

	}

	/*

	 * retro compatibility method for import.xml file

	 * @see org.txm.searchengine.cqp.corpus.Corpus#getLocale()

			this.setUserName(e.getAttribute(NAME));

			this.pID = "S" + getNextSubcorpusCounter();

			this.pQuery = new CQLQuery(e.getAttribute("query")); //$NON-NLS-1$

			NodeList subcorpusElems = e.getElementsByTagName("subcorpus"); //$NON-NLS-1$

			for (int i = 0; i < subcorpusElems.getLength(); i++) {

				Element subcorpusElem = (Element) subcorpusElems.item(i);

					Log.warning(TXMCoreMessages.bind(TXMCoreMessages.failedToRestoreTheP0SubcorpusOfP1P2, this.pID, subcorpusElem.getAttribute("name"), ex)); //$NON-NLS-1$

				}

			}

			NodeList partitionElems = e.getElementsByTagName("partition"); //$NON-NLS-1$

			for (int i = 0; i < partitionElems.getLength(); i++) {

				Element partitionElem = (Element) partitionElems.item(i);

				String name = partitionElem.getAttribute("name"); //$NON-NLS-1$

				List<String> names = new ArrayList<>();

				List<String> queries = new ArrayList<>();

				NodeList partElems = partitionElem.getElementsByTagName("part"); //$NON-NLS-1$

				for (int j = 0; j < partElems.getLength(); j++) {

					Element part = (Element) partElems.item(j);

		// return super.load();

		return true;

	}

	@Override

	public boolean canCompute() {

		return getUserName() != null && getUserName().length() > 0 &&

				((pQuery != null && pQuery.getQueryString().length() > 0) || qresult != null);

	}

	/*

	 * (non-Javadoc)

	 * @see

			throw new InvalidCqpIdException(TXMCoreMessages.bind(CQPSearchEngineCoreMessages.p0IsNotAValidCQPIDForASubcorpusItMustBeAnUppercaseCharacterFollowedByLowercaseCharacters, pID));

		return true;

	}

	@Override

	public void clean() {

		super.clean();

		// nothing to do if the corpus has not yet been computed

		if (this.hasBeenComputedOnce()) {

			try {

				Log.printStackTrace(e);

			}

		}

		qresult = null;

		selectionResult = null;

	}

	@Override

	public List<? extends Match> getMatches() {

		if (qresult == null) { // not computed

			return new ArrayList<>();

		}

	}

	public int getNMatch() {

		try {

			return qresult.getNMatch();

			return 0;

		}

	}

	// protected void finalize() throws Throwable {

	// try {

	// //

	// super.finalize();

	// }

	// }

	/*

	 * (non-Javadoc)

	 * @see

	public String getQualifiedCqpId() {

		return getMainCorpus().getCqpId() + ":" + this.pID; //$NON-NLS-1$

	}

	// /**

	// * Register to parent.

	// *

	//

	// this._load();

	// }

	/**

	 * Gets the query.

	 *

	public IQuery getQuery() {

		return pQuery;

	}

	@Override

	public String getResultType() {

		return "Corpus";

	}

	public SelectionResult getSelectionResult() {

		return selectionResult;

	}

	/**

	 * Returns the number of occurrences in the subcorpus.

	 * 

	@Override

	public int getSize() throws CqiClientException {

		if (!this.hasBeenComputedOnce()) return 0;

		if (this.size == -1) {

			// Log.finest(TXMCoreMessages.bind(TXMCoreMessages.SUBCORPUS_SIZE, new Object[]{this.pName, "N/A"}));

			long start = System.currentTimeMillis();

			try {

				AbstractCqiClient cqiClient = CorpusManager.getCorpusManager().getCqiClient();

				String qid = this.getQualifiedCqpId();

						throw new UnexpectedAnswerException();

					}

					this.size = 0;

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

						size += matchend[i] - match[i] + 1;

					}

		}

		return this.size;

	}

	@Override

	public int[] getStartLimits(String sup) throws IOException,

	CqiServerError, InvalidCqpIdException, CqiClientException {

		return this.getMainCorpus().getStartLimits(sup);

	}

	/*

	 * (non-Javadoc)

	 * @see

			throws CqiClientException {

		return getMainCorpus().getStructuralUnit(name);

	}

	/*

	 * (non-Javadoc)

	 * @see org.txm.searchengine.cqp.corpus.Corpus#getStructuralUnits()

	public List<StructuralUnit> getStructuralUnits() throws CqiClientException {

		return getMainCorpus().getStructuralUnits();

	}

	public SelectionResult initSelectionResult(Element e) {

		if (e != null) {

			selectionResult = new SelectionResult();

			NodeList selectionList = e.getElementsByTagName("selection"); //$NON-NLS-1$

			for (int i = 0; i < selectionList.getLength();) {

				Element selection = (Element) selectionList.item(i); // the selection element

				NodeList textList = selection.getElementsByTagName("selText"); // get text ids //$NON-NLS-1$

				for (int j = 0; j < textList.getLength(); j++) {

					Element text = (Element) textList.item(j);

					selectionResult.add(text.getAttribute("id")); //$NON-NLS-1$

				}

				NodeList critList = selection.getElementsByTagName("selCrit"); // get the criteria //$NON-NLS-1$

				for (int j = 0; j < critList.getLength(); j++) {

					Element crit = (Element) critList.item(j);

		}

		return selectionResult;

	}

	@Override

	public boolean loadParameters() throws Exception {

		String q = this.getStringParameterValue(TXMPreferences.QUERY);

		if (!q.isEmpty()) {

			pQuery = new CQLQuery(q);

		}

		return true;

	}

	@Override

	public boolean saveParameters() throws Exception {

		if (pQuery != null) {

		}

		return true;

	}

	/**

	 * Instantiates a new subcorpus.

	 * 

	 *             {@link CQPCorpus#createSubcorpus(CQLQuery, String)}

	 */

	protected void setParameters(String pID, String name, CQLQuery query) throws InvalidCqpIdException {

		this.pID = pID;

		this.pQuery = query;

		this.setUserName(name);

	}

	/**

	 * 

	 * @param cqpId

	 * @param queryResult

	 */

	public void setParameters(String cqpId, String name, QueryResult queryResult) {

		this.pID = cqpId;

		this.setUserName(name);

		this.pQuery = queryResult.getQuery();

		this.qresult = queryResult;

		this.setDirty();

	}

	/**

	 * Sets the query to use.

	 * 

	public void setQuery(CQLQuery query) {

		this.pQuery = query;

	}

	// TODO merge SelectionResult and Subcorpus ?

	public void setSelectionResult(SelectionResult selectionResult) {

		this.selectionResult = selectionResult;

		// getSelfElement().appendChild(selectionElem);// append selection elem to self

		// }

	}

	/*

	 * (non-Javadoc)

	 * @see java.lang.Object#toString()

	public String toString() {

		return this.getName();

	}

	@Override

	@Deprecated

	public boolean _toTxt(File outfile, String encoding, String colseparator, String txtseparator) throws Exception {

		return false;

	}

	@Override

	public void setIsModified(boolean b) {

		// nothing

	}

	@Override

	public CorpusBuild getRootCorpusBuild() {

		return getMainCorpus();

	}

	/**

	 * Return the CQP START positions of the main corpus texts

	 */

		}

		return textLimits;

	}

	/**

	 * Return the CQP END positions of the main corpus texts

	 */

		}

		return textEndLimits;

	}

	/**

	 * Gets the nb texts.

	 *

	@Override

	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<>();

		// filter structs with matches

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

		}

		return structsIncorpus;

	}

	/**

	 * 

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

	 */

	@Override

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

		if (cqpTextIDS == null) {

			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);

			}

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

		}

		return cqpTextIDS;

	}

	/**

	 * Gets the texts ids and order number in corpus.

	 *

			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;

	}

	@Override

	public String getName() {

		return this.getCorpusParent().getSimpleName() + TXMPreferences.PARENT_NAME_SEPARATOR + this.getSimpleName();

	}

	@Override

	public String getDetails() {

		try {

	@Override

	public List<?> isBuildValid() {

		if (this.getParent() != null) return new LinkedList<String>(); // ok

		return Arrays.asList("No parent corpus result");

	}

	@Override

	public String isReady() {

		if (!hasBeenComputedOnce()) return "the subcorpus is not a computed TXMResult";

		try {

			int s = this.getSize();

			if (s >= 0) return null;