mirror of
https://github.com/yacy/yacy_search_server.git
synced 2024-09-21 00:00:13 +02:00
19fd13d3bc
YaCy supports now the storage to remote solr indexes. More federated storage (and search) methods may follow. The remote index scheme is the same as produced by the SolrCell; see http://wiki.apache.org/solr/ExtractingRequestHandler Because this default scheme is used, the default example scheme can be used as solr configuration This is also the same scheme that solr uses if documents are imported with apache tika. federated solr storage is switched off by default. To use this, do the following: - set federated.service.solr.indexing.enabled = true - download solr from http://www.apache.org/dyn/closer.cgi/lucene/solr/ - extract the solr (3.1) package, 'cd example' and start solr with 'java -jar start.jar' - start yacy and then start a crawler. The crawler will fill both, YaCy and solr indexes. - to check whats in solr after indexing, open http://localhost:8983/solr/admin/ Until now it is not possible to use the solr index to search with YaCy in that solr index. This functionality is now available for two reasons: 1) to compare the functionality of Solr and YaCy and to compare the search speed 2) to use YaCy as a search appliance for people who need a crawler or other source harvesting methods that YaCy provides (like dublin core reading, wikimedia dump reading, rss feed reader etc) if people still want to use solr instead of YaCy. git-svn-id: https://svn.berlios.de/svnroot/repos/yacy/trunk@7654 6c8d7289-2bf4-0310-a012-ef5d649a1542
83 lines
2.8 KiB
Java
83 lines
2.8 KiB
Java
import java.io.IOException;
|
|
import java.util.Iterator;
|
|
|
|
import net.yacy.cora.document.UTF8;
|
|
import net.yacy.cora.protocol.RequestHeader;
|
|
import net.yacy.kelondro.blob.Tables;
|
|
import net.yacy.kelondro.logging.Log;
|
|
import de.anomic.data.UserDB;
|
|
import de.anomic.data.ymark.YMarkTables;
|
|
import de.anomic.data.ymark.YMarkUtil;
|
|
import de.anomic.search.Switchboard;
|
|
import de.anomic.server.serverObjects;
|
|
import de.anomic.server.serverSwitch;
|
|
|
|
|
|
public class get_ymark {
|
|
|
|
private static Switchboard sb = null;
|
|
private static serverObjects prop = null;
|
|
|
|
public static serverObjects respond(final RequestHeader header, final serverObjects post, final serverSwitch env) {
|
|
sb = (Switchboard) env;
|
|
prop = new serverObjects();
|
|
|
|
//boolean tags = false;
|
|
|
|
final UserDB.Entry user = sb.userDB.getUser(header);
|
|
final boolean isAdmin = (sb.verifyAuthentication(header, true));
|
|
final boolean isAuthUser = user!= null && user.hasRight(UserDB.AccessRight.BOOKMARK_RIGHT);
|
|
Iterator<Tables.Row> bookmarks = null;
|
|
|
|
if(isAdmin || isAuthUser) {
|
|
final String bmk_user = (isAuthUser ? user.getUserName() : YMarkTables.USER_ADMIN);
|
|
|
|
if(post.containsKey(YMarkTables.BOOKMARK.TAGS.key())) {
|
|
//tags = true;
|
|
final String[] tagArray = YMarkUtil.cleanTagsString(post.get(YMarkTables.BOOKMARK.TAGS.key())).split(YMarkUtil.TAGS_SEPARATOR);
|
|
try {
|
|
bookmarks = sb.tables.bookmarks.getBookmarksByTag(bmk_user, tagArray);
|
|
} catch (IOException e) {
|
|
Log.logException(e);
|
|
}
|
|
}
|
|
/*
|
|
if(post.containsKey(YMarkTables.BOOKMARK.FOLDERS.key())) {
|
|
final String[] folderArray = YMarkTables.cleanFoldersString(post.get(YMarkTables.BOOKMARK.FOLDERS.key())).split(YMarkTables.TAGS_SEPARATOR);
|
|
try {
|
|
if(tags)
|
|
bookmarks.retainAll(sb.tables.bookmarks.folders.getBookmarkIds(bmk_user, folderArray));
|
|
else
|
|
bookmarks.addAll(sb.tables.bookmarks.folders.getBookmarkIds(bmk_user, folderArray));
|
|
} catch (IOException e) {
|
|
Log.logException(e);
|
|
} catch (RowSpaceExceededException e) {
|
|
Log.logException(e);
|
|
}
|
|
}
|
|
*/
|
|
putBookmarks(bookmarks);
|
|
|
|
} else {
|
|
prop.put(YMarkTables.USER_AUTHENTICATE,YMarkTables.USER_AUTHENTICATE_MSG);
|
|
}
|
|
// return rewrite properties
|
|
return prop;
|
|
}
|
|
|
|
private static void putBookmarks(final Iterator<Tables.Row> bit) {
|
|
int count = 0;
|
|
while(bit.hasNext()) {
|
|
Tables.Row bmk_row = bit.next();
|
|
if (bmk_row != null) {
|
|
prop.putXML("bookmarks_"+count+"_id", UTF8.String(bmk_row.getPK()));
|
|
for (YMarkTables.BOOKMARK bmk : YMarkTables.BOOKMARK.values()) {
|
|
prop.putXML("bookmarks_"+count+"_"+bmk.key(), bmk_row.get(bmk.key(),bmk.deflt()));
|
|
}
|
|
count++;
|
|
}
|
|
}
|
|
prop.put("bookmarks", count);
|
|
}
|
|
}
|