solrcopy 0.9.2

Command line tool useful for migration, transformations, backup, and restore of documents stored inside cores of Apache Solr
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38

use super::{args::Execute, connection::SolrClient};
use log::{debug, info};

pub(crate) fn create_main(params: &Execute) -> Result<(), Box<dyn std::error::Error>> {
    debug!("# CREATE: {:?}", params);

    let mut client = SolrClient::new();
    let sinf = client.get_solr_info(&params.options.url)?;
    info!(
        "# URL: '{}', version:  {}, standalone: {}",
        params.options.url, sinf.version, sinf.standalone
    );

    let core_name = params.options.core.clone();

    let std8 =
        r#"{ "create": { "name": "%s", "configSet": "/var/solr/data/configsets/_default" } }"#;
    let std9 = r#"{ "create": { "name": "%s", "configSet": "_default" } }"#;
    let stdx = r#"{ "name": "%s", "configSet": "_default" }"#;
    let cld9 = r#"{ "name": "%s", "config": "_default", "numShards": 1 }"#;

    let std = match sinf.version {
        8 => std8,
        9 => std9,
        _ => stdx,
    };
    let json = if sinf.standalone { std } else { cld9 };
    let content = json.replace("%s", &core_name);

    let api_url = if sinf.standalone { "api/cores" } else { "api/collections" };
    let url = params.options.get_url_from(api_url);

    let res = client.post_as_json(&url, &content)?;

    info!("Created the core {} in {}:\n  {}", core_name, url, res);

    Ok(())
}