solr与.net系列课程(四)solr查询参数的讲解与.net如何获取solr数据

时间  2019-11-17
标签 solr 系列 课程 查询 参数 讲解 如何 获取 数据 繁體版
原文   原文链接

 solr与.net系列课程(四)solr查询参数的讲解与.net如何获取solr数据php

      上一节咱们完成了solr链接数据库,细心的朋友会发现一个问题,就是solr其实和语言没有任何关系,配置完成后任何语言均可以直接调用,本章咱们主要对solr的查询作出讲解,而后就是新接触的人最关心的.net如何获取solr中的数据.ajax

      本节我准备了一个300万左右的数据表,为你们作演示sql

      而后咱们开始配置schema.xml 文件:数据库

    <field name="id" type="string" indexed="true" stored="true" required="true" /> 
     <field name="title" type="text_cn" indexed="true" stored="true" multiValued="false" /> 
    <field name="area" type="string" indexed="true" stored="true" />
    <field name="industry" type="string" indexed="true" stored="true" />
    <field name="industrys" type="string" indexed="true" stored="true" />
    <field name="body" type="smartChnText" indexed="true" stored="true"/>
    <field name="adddate" type="date" indexed="true" stored="true" multiValued="false"/>
    <field name="columns" type="smartChnText" indexed="true" stored="true"/>
    <field name="sorts" type="string" indexed="true" stored="true"/>
    <field name="url" type="string" indexed="true" stored="true" required="true" />
    <field name="orderColumn" type="string" indexed="true" stored="true"/>
    <field name="phase" type="string" indexed="true" stored="true"/>
    <field name="phasetype" type="string" indexed="true" stored="true"/>
    <field name="pfund" type="tfloat" indexed="true" stored="true"/>
    <field name="flag" type="string" indexed="true" stored="true" />

   这里说明一下,数据表中的数据能够选择行的存入solr中,想存哪一个就配置哪一个就好了apache

      type="text_cn" 就是我配置的ik分词器,type="smartChnText"是solr自带的分词器,分词效果通常,但也要配置,直接在配置ik分词器的位置粘贴以下代码便可:json

<!-- 加入smartcn 中文分词器 text_newcn--> 
<fieldType name="smartChnText" class="solr.TextField"  >  

    <analyzer  class="org.apache.lucene.analysis.cn.smart.SmartChineseAnalyzer"/>  

 </fieldType>

        这里强调一下,分词器有不少种,想要哪一种就用哪一种浏览器

        配置完成后开始配置data-confing.xml文件ruby

<?xml version="1.0" encoding="UTF-8"?>  
<dataConfig>
<dataSource driver="com.microsoft.sqlserver.jdbc.SQLServerDriver" url="jdbc:sqlserver://192.168.0.8;DatabaseName=BHI_DATABASE" user="sa" password="123"/>
<document name="Info">
<entity name="Biddings" pk="OriginalID" transformer="ClobTransformer"
 
query="SELECT OriginalID,'项目标讯' as orderColumn, '项目标讯' as columns ,'${dataimporter.last_index_time}' as ColumnID,dbo.ShowLabelName(Area) as Area,Pfund,ColumnID as flag,category,dbo.ShowLabelName(Industry) as Industry, Industry as Industrys,Title,( dbo.fun_joinInfo(OriginalID) + CONVERT(VARCHAR(MAX),description) ) AS description,AddDate FROM BHI_DATABASE.dbo.Info_Bidding"
deltaImportQuery="SELECT  OriginalID,'项目标讯' as orderColumn, '项目标讯' as columns ,'${dataimporter.last_index_time}' as ColumnID,dbo.ShowLabelName(Area) as Area,Pfund,ColumnID as flag,category,dbo.ShowLabelName(Industry) as Industry,Industry as Industrys,Title,( dbo.fun_joinInfo(OriginalID) + CONVERT(VARCHAR(MAX),description) ) AS description,AddDate FROM BHI_DATABASE.dbo.Info_Bidding  where adddate > '${dataimporter.last_index_time}'"
deltaQuery="SELECT OriginalID FROM BHI_DATABASE.dbo.Info_Bidding where  adddate > '${dataimporter.last_index_time}'">

           <field column="OriginalID"            name="id"            />
           <field column="title"        name="title"        />
           <field column="area"        name="area"          />
             <field column="industry"    name="industry"    />
                <field column="industrys"    name="industrys"    />
           <field column="description"        name="body"        />
           <field column="adddate"        name="adddate"        />
           <field column="ColumnID"    name="sorts"    />
           <field column="columns"    name="columns" /> 
           <field column="OriginalID"    name="url"    />
           <field column="orderColumn"    name="orderColumn" /> 
            <field column="Pfund"    name="pfund" /> 
             <field column="category"    name="phase" /> 
              <field column="flag"    name="flag" /> 
          
</entity>

</document>

     这里我没有用简单的select id,name ...from 表名这种简单的sql语句,而是写了一个带有别名,函数的sql语句,就是告诉你们,这里能够写任何sql语句,但视图,表链接最好不要使用,要使用表链接的话我上节课已经讲解了,想用的朋友能够回去看看.服务器

     Solr 是如何查询的呢?这里先列出solr查询所须要的参数函数

     经常使用

     q - 查询字符串，必须的。
     fl - 指定返回那些字段内容，用逗号或空格分隔多个。
     start - 返回第一条记录在完整找到结果中的偏移位置，0开始，通常分页用。
     rows - 指定返回结果最多有多少条记录，配合start来实现分页。
     sort - 排序，格式：sort=<field name>+<desc|asc>[,<field name>+<desc|asc>]… 。示例：（inStock desc, price asc）表示先 “inStock” 降序, 再 “price” 升序，默认是相关性降序。
     wt - (writer type)指定输出格式，能够有 xml, json, php, phps, 后面 solr 1.3增长的，要用通知咱们，由于默认没有打开。
     fq - （filter query）过虑查询，做用：在q查询符合结果中同时是fq查询符合的，例如：q=mm&fq=date_time:[20081001 TO 20091031]，找关键字mm，而且date_time是20081001到20091031之间的。官方文档：http://wiki.apache.org/solr/CommonQueryParameters#head-6522ef80f22d0e50d2f12ec487758577506d6002
不经常使用

     q.op - 覆盖schema.xml的defaultOperator（有空格时用"AND"仍是用"OR"操做逻辑），通常默认指定
     df - 默认的查询字段，通常默认指定
     qt - （query type）指定那个类型来处理查询请求，通常不用指定，默认是standard。
     其它

     indent - 返回的结果是否缩进，默认关闭，用 indent=true|on 开启，通常调试json,php,phps,ruby输出才有必要用这个参数。
     version - 查询语法的版本，建议不使用它，由服务器指定默认值。

     

      那么咱们来实际查询一个试试

      Selet * from table where area=’重庆’ and columns=’项目标讯’  --这个转换成solr语句怎么写?

 

    http://127.0.0.1:8080/solr/collection1/select?q=area:重庆&fq=columns:项目标讯&wt=xml&indent=true

    或

    http://127.0.0.1:8080/solr/collection1/select?q=*:*&fq=area:重庆&fq=columns:项目标讯&wt=xml&indent=true

    q是主查询 fq是辅查下(能够多个)

    咱们来看看效果,直接在浏览器中输入上面的地址:

     像不像咱们使用的ajax请求,请求连接获取数据

     我想查询部分字段怎么办呢,使用fl参数

     http://127.0.0.1:8080/solr/collection1/select?fl=title,orderColumn,area,columns,id&q=*:*&fq=area:重庆&fq=columns:项目标讯&wt=json&indent=true

     看看效果,这个返回json数据:

      如今咱们练习一个

      Select top 2 title,orderColumn,area,columns,id from table where area=山东 OR area= 福建 and columns=项目标讯 order by adddate desc  

      转换为solr语句:http://127.0.0.1:8080/solr/collection1/select?fl=title,orderColumn,area,columns,id&q=*:*&fq=area:福建+OR+area:山东&fq=columns:项目标讯  &wt=json&indent=true&&start=0&rows=2&sort=adddate desc

     上面列出的查询条件均可以自由组合( OR 和 AND 要大写,小写有时不出数据)

     好了下面在就该说一下你们最关心的问题了,.net如何获取这些数据(这里先使用最原始的方式)

    首先建立个程序,随便建立个aspx页面,在后台输入以下代码

   

using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using System.Web.UI;
using System.Web.UI.WebControls;
using System.Net;
using System.IO;
using System.Text;

namespace solr实例
{
    public partial class _Default : System.Web.UI.Page
    {
        protected void Page_Load(object sender, EventArgs e)
        {
            string solr_url = @"http://127.0.0.1:8080/solr/collection1/select?fl=title,orderColumn,area,columns,id&q=*:*&fq=area:山东 OR area:福建 &fq=columns:项目标讯&wt=xml&indent=true&&start=0&rows=10&sort=adddate desc";

            WebRequest wr = WebRequest.Create(solr_url);
            Stream s = wr.GetResponse().GetResponseStream();
            StreamReader sr = new StreamReader(s, Encoding.UTF8);
            string result = sr.ReadToEnd();
        }
    }
}

执行如下看看 result中有没有数据?

 

      这样咱们就获得数据了,可是这是一个字符串啊,怎么使用呢,我我这里使用数据契约将上述内容转化为数据实体,数据契约不了解的话去网上查一查,很好理解的.

      首先建立契约类

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Runtime.Serialization;
namespace ClassLibrary1
{
    [DataContract]
    public class Solr_Projects
    {

        [DataMember(Name = "responseHeader")]
        public Solr_Projects_ResponseHeader ResponseHeader { get; set; }

        [DataMember(Name = "response")]
        public Response Response { get; set; }
    }

    [DataContract]
    public class Solr_Projects_ResponseHeader
    {

        [DataMember(Name = "status")]
        public string Status { get; set; }

        [DataMember(Name = "QTime")]
        public string QTime { get; set; }

        [DataMember(Name = "params")]
        public Params Params { get; set; }
    }

    [DataContract]
    public class Params
    {

        [DataMember(Name = "indent")]
        public string Indent { get; set; }

        [DataMember(Name = "start")]
        public string Start { get; set; }

        [DataMember(Name = "q")]
        public string Q { get; set; }

        [DataMember(Name = "wt")]
        public string Wt { get; set; }

        [IgnoreDataMember]
        //[DataMember(Name = "fq")]
        public string Fq { get; set; }

        [DataMember(Name = "version")]
        public string Version { get; set; }

        [DataMember(Name = "rows")]
        public string Rows { get; set; }
    }

    [DataContract(Name = "response")]
    public class Response
    {

        [DataMember(Name = "numFound")]
        public string NumFound { get; set; }

        [DataMember(Name = "start")]
        public string Start { get; set; }

        [DataMember(Name = "solrUrl")]
        public string SolrUrl { get; set; }

        [DataMember(Name = "docs")]
        public Docs[] Docs { get; set; }
    }

    [DataContract]
    public class Docs
    {

        [DataMember(Name = "title")]
        public string Title { get; set; }

        //[IgnoreDataMember]
        [DataMember(Name = "orderColumn")]
        public string OrderColumn { get; set; }

        [IgnoreDataMember]
        //[DataMember(Name = "body")]
        public string Body { get; set; }

        [DataMember(Name = "area")]
        public string AreaName { get; set; }

        [DataMember]
        public string AreaID { get; set; }

        [DataMember(Name = "columns")]
        public string Columns { get; set; }

        [DataMember(Name = "id")]
        public string Id { get; set; }

        [IgnoreDataMember]
        //[DataMember(Name = "url")]
        public string Url { get; set; }

        [DataMember(Name = "phase")]
        public string PhaseID { get; set; }

        [DataMember]
        public string PhaseName { get; set; }

        [DataMember(Name = "adddate")]
        public string AddDate { get; set; }

        [DataMember(Name = "industry")]
        public string IndustryName { get; set; }

        [DataMember]
        public string IndustryId { get; set; }
        [DataMember(Name = "phasetype")]
        public string PhaseType { get; set; }

        [DataMember(Name = "pfund")]
        public string Pfund { get; set; }

        [DataMember(Name = "categroy")]
        public string Category { get; set; }
    }
}

而后咱们就能够用这个契约类去获取数据了(上面的属性是和数据对应的,名称相同的就会存储相应的数据,没有的就不存,我这个里面数据比较多,实际上只用了五个字段)

using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using System.Web.UI;
using System.Web.UI.WebControls;
using System.Net;
using System.IO;
using System.Text;
using ClassLibrary1;
using System.Runtime.Serialization;
using System.Web.Script.Serialization;
using System.Runtime.Serialization.Json;
namespace solr实例
{
    public partial class _Default : System.Web.UI.Page
    {
        protected void Page_Load(object sender, EventArgs e)
        {
            string solr_url = @"http://127.0.0.1:8080/solr/collection1/select?fl=title,orderColumn,area,columns,id&q=*:*&fq=area:山东 OR area:福建 &fq=columns:项目标讯&wt=json&indent=true&&start=0&rows=10&sort=adddate desc";

            WebRequest wr = WebRequest.Create(solr_url);
            Stream s = wr.GetResponse().GetResponseStream();
            StreamReader sr = new StreamReader(s, Encoding.UTF8);
            string result = sr.ReadToEnd();
            Solr_Projects solr_result;

            //反序列化
            using (MemoryStream ms = new MemoryStream(Encoding.UTF8.GetBytes(result)))
            {
                DataContractJsonSerializer serializer = new DataContractJsonSerializer(typeof(Solr_Projects));
                solr_result = (Solr_Projects)serializer.ReadObject(ms);
            }

            solr_result.Response.SolrUrl = solr_url + "&numFound=" + solr_result.Response.NumFound;
            Docs[] docs = solr_result.Response.Docs;//获取须要展现信息的对象

            

        }
    }

}

看看结果:

      个人语句中只查询了五个字段,因此其余的都是null,好了,如今字符串已经转换为数据实体了,数据实体咱们就能够想怎么办就怎么办了,这里说明一下,这是最原始的的使用方式,url须要,本身去拼接

咱们.net中有solr的客户端 ,叫solrnet,它是专门操做solr查询与获取数据的,很是方便好用,这个我之后会教你们怎么使用,今天就先讲的这里吧.

 

qq群: 424259523

相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程