修改包名

This commit is contained in:
xgc 2024-05-23 11:17:38 +08:00
parent 567c475722
commit 466bbebb95
62 changed files with 198 additions and 203 deletions

View File

@ -2,7 +2,7 @@
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"> xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
<groupId>io.github.javpower</groupId> <groupId>org.dromara</groupId>
<artifactId>milvus-core-demo</artifactId> <artifactId>milvus-core-demo</artifactId>
<version>0.0.1-SNAPSHOT</version> <version>0.0.1-SNAPSHOT</version>
<name>milvus-core-demo</name> <name>milvus-core-demo</name>
@ -15,7 +15,7 @@
</properties> </properties>
<dependencies> <dependencies>
<dependency> <dependency>
<groupId>io.github.javpower</groupId> <groupId>org.dromara</groupId>
<artifactId>milvus-plus-core</artifactId> <artifactId>milvus-plus-core</artifactId>
<version>2.4.0-SNAPSHOT</version> <version>2.4.0-SNAPSHOT</version>
</dependency> </dependency>
@ -49,7 +49,7 @@
<artifactId>spring-boot-maven-plugin</artifactId> <artifactId>spring-boot-maven-plugin</artifactId>
<version>${spring-boot.version}</version> <version>${spring-boot.version}</version>
<configuration> <configuration>
<mainClass>io.github.javpower.milvus.demo.MilvusDemoApplication</mainClass> <mainClass>org. dromara.milvus.demo.MilvusDemoApplication</mainClass>
<skip>true</skip> <skip>true</skip>
</configuration> </configuration>
<executions> <executions>

View File

@ -1,13 +1,13 @@
package io.github.javpower.milvus.demo.java; package org.dromara.milvus.demo.java;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.google.common.collect.Lists; import com.google.common.collect.Lists;
import io.github.javpower.milvus.demo.model.Face; import org.dromara.milvus.demo.model.Face;
import io.github.javpower.milvus.plus.core.mapper.BaseMilvusMapper; import org.dromara.milvus.plus.core.mapper.BaseMilvusMapper;
import io.github.javpower.milvus.plus.model.MilvusProperties; import org.dromara.milvus.plus.model.MilvusProperties;
import io.github.javpower.milvus.plus.model.vo.MilvusResp; import org.dromara.milvus.plus.model.vo.MilvusResp;
import io.github.javpower.milvus.plus.model.vo.MilvusResult; import org.dromara.milvus.plus.model.vo.MilvusResult;
import io.github.javpower.milvus.plus.service.impl.MilvusClientBuild; import org.dromara.milvus.plus.service.impl.MilvusClientBuild;
import io.milvus.v2.client.MilvusClientV2; import io.milvus.v2.client.MilvusClientV2;
import java.util.List; import java.util.List;
@ -16,8 +16,8 @@ public class JavaTest {
public static void main(String[] args) throws InterruptedException { public static void main(String[] args) throws InterruptedException {
MilvusProperties properties=new MilvusProperties(); MilvusProperties properties=new MilvusProperties();
properties.setEnable(true); properties.setEnable(true);
properties.setUri("xxxxx"); properties.setUri("https://in03-a5357975ab80da7.api.gcp-us-west1.zillizcloud.com");
properties.setToken("xxxx"); properties.setToken("xxx");
properties.setPackages(Lists.newArrayList("io.github.javpower.milvus.demo.model")); properties.setPackages(Lists.newArrayList("io.github.javpower.milvus.demo.model"));
MilvusClientBuild build = new MilvusClientBuild(properties); MilvusClientBuild build = new MilvusClientBuild(properties);
build.initialize(); build.initialize();
@ -31,6 +31,7 @@ public class JavaTest {
//标量查询 //标量查询
MilvusResp<List<MilvusResult<Face>>> query2 = mapper.queryWrapper() MilvusResp<List<MilvusResult<Face>>> query2 = mapper.queryWrapper()
.eq(Face::getPersonId, 2L) .eq(Face::getPersonId, 2L)
.partition("face_01")
.topK(3) .topK(3)
.query(); .query();
System.out.println("标量查询 query--queryWrapper---{}"+JSONObject.toJSONString(query2)); System.out.println("标量查询 query--queryWrapper---{}"+JSONObject.toJSONString(query2));

View File

@ -1,9 +1,9 @@
package io.github.javpower.milvus.demo.model; package org.dromara.milvus.demo.model;
import io.github.javpower.milvus.plus.annotation.*;
import io.milvus.v2.common.DataType; import io.milvus.v2.common.DataType;
import io.milvus.v2.common.IndexParam; import io.milvus.v2.common.IndexParam;
import lombok.Data; import lombok.Data;
import org.dromara.milvus.plus.annotation.*;
import java.util.List; import java.util.List;

View File

@ -3,7 +3,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"> xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
<parent> <parent>
<groupId>io.github.javpower</groupId> <groupId>org.dromara</groupId>
<artifactId>milvus-plus-parent</artifactId> <artifactId>milvus-plus-parent</artifactId>
<version>${revision}</version> <version>${revision}</version>
<relativePath>../milvus-plus-parent/pom.xml</relativePath> <relativePath>../milvus-plus-parent/pom.xml</relativePath>
@ -21,7 +21,7 @@
<artifactId>spring-boot-starter-web</artifactId> <artifactId>spring-boot-starter-web</artifactId>
</dependency> </dependency>
<dependency> <dependency>
<groupId>io.github.javpower</groupId> <groupId>org.dromara</groupId>
<artifactId>milvus-plus-core</artifactId> <artifactId>milvus-plus-core</artifactId>
</dependency> </dependency>
<dependency> <dependency>

View File

@ -1,4 +1,4 @@
package io.github.javpower.milvus.plus.entity; package org.dromara.milvus.plus.entity;
import lombok.Data; import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties; import org.springframework.boot.context.properties.ConfigurationProperties;

View File

@ -1,7 +1,7 @@
package io.github.javpower.milvus.plus.mapper; package org.dromara.milvus.plus.mapper;
import io.github.javpower.milvus.plus.core.mapper.BaseMilvusMapper; import org.dromara.milvus.plus.core.mapper.BaseMilvusMapper;
import io.github.javpower.milvus.plus.util.SpringUtils; import org.dromara.milvus.plus.util.SpringUtils;
import io.milvus.v2.client.MilvusClientV2; import io.milvus.v2.client.MilvusClientV2;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;

View File

@ -1,6 +1,6 @@
package io.github.javpower.milvus.plus.service; package org.dromara.milvus.plus.service;
import io.github.javpower.milvus.plus.entity.MilvusProperties; import org.dromara.milvus.plus.entity.MilvusProperties;
import io.milvus.v2.client.MilvusClientV2; import io.milvus.v2.client.MilvusClientV2;
import org.springframework.beans.BeanUtils; import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
@ -20,7 +20,7 @@ public class MilvusInit extends AbstractMilvusClientBuilder {
// Spring会调用这个方法来初始化client // Spring会调用这个方法来初始化client
@PostConstruct @PostConstruct
public void initialize() { public void initialize() {
io.github.javpower.milvus.plus.model.MilvusProperties milvusProperties1=new io.github.javpower.milvus.plus.model.MilvusProperties(); org.dromara.milvus.plus.model.MilvusProperties milvusProperties1=new org.dromara.milvus.plus.model.MilvusProperties();
BeanUtils.copyProperties(milvusProperties,milvusProperties1); BeanUtils.copyProperties(milvusProperties,milvusProperties1);
super.setProperties(milvusProperties1); super.setProperties(milvusProperties1);
super.initialize(); super.initialize();

View File

@ -1,4 +1,4 @@
package io.github.javpower.milvus.plus.util; package org.dromara.milvus.plus.util;
import org.springframework.beans.BeansException; import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext; import org.springframework.context.ApplicationContext;

View File

@ -3,7 +3,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"> xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
<parent> <parent>
<groupId>io.github.javpower</groupId> <groupId>org.dromara</groupId>
<artifactId>milvus-plus-parent</artifactId> <artifactId>milvus-plus-parent</artifactId>
<version>${revision}</version> <version>${revision}</version>
<relativePath>../milvus-plus-parent/pom.xml</relativePath> <relativePath>../milvus-plus-parent/pom.xml</relativePath>

View File

@ -1,12 +0,0 @@
package io.github.javpower.milvus.plus.service.impl;
import io.github.javpower.milvus.plus.model.MilvusProperties;
import io.github.javpower.milvus.plus.service.AbstractMilvusClientBuilder;
public class MilvusClientBuild extends AbstractMilvusClientBuilder {
public MilvusClientBuild(MilvusProperties properties) {
super.setProperties(properties);
}
}

View File

@ -1,4 +1,4 @@
package io.github.javpower.milvus.plus.annotation; package org.dromara.milvus.plus.annotation;
import java.lang.annotation.ElementType; import java.lang.annotation.ElementType;
import java.lang.annotation.Retention; import java.lang.annotation.Retention;

View File

@ -1,4 +1,4 @@
package io.github.javpower.milvus.plus.annotation; package org.dromara.milvus.plus.annotation;
import java.lang.annotation.ElementType; import java.lang.annotation.ElementType;
import java.lang.annotation.Retention; import java.lang.annotation.Retention;

View File

@ -1,4 +1,4 @@
package io.github.javpower.milvus.plus.annotation; package org.dromara.milvus.plus.annotation;
import io.milvus.v2.common.DataType; import io.milvus.v2.common.DataType;

View File

@ -1,4 +1,4 @@
package io.github.javpower.milvus.plus.annotation; package org.dromara.milvus.plus.annotation;
import io.milvus.v2.common.IndexParam; import io.milvus.v2.common.IndexParam;

View File

@ -1,4 +1,4 @@
package io.github.javpower.milvus.plus.annotation; package org.dromara.milvus.plus.annotation;
import java.lang.annotation.ElementType; import java.lang.annotation.ElementType;
import java.lang.annotation.Retention; import java.lang.annotation.Retention;

View File

@ -1,4 +1,4 @@
package io.github.javpower.milvus.plus.builder; package org.dromara.milvus.plus.builder;
import io.milvus.exception.MilvusException; import io.milvus.exception.MilvusException;
import io.milvus.v2.client.MilvusClientV2; import io.milvus.v2.client.MilvusClientV2;

View File

@ -1,4 +1,4 @@
package io.github.javpower.milvus.plus.cache; package org.dromara.milvus.plus.cache;
import java.util.Map; import java.util.Map;
import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentHashMap;

View File

@ -1,6 +1,6 @@
package io.github.javpower.milvus.plus.cache; package org.dromara.milvus.plus.cache;
import io.github.javpower.milvus.plus.model.MilvusEntity; import org.dromara.milvus.plus.model.MilvusEntity;
import lombok.Data; import lombok.Data;
/** /**
* @author xgc * @author xgc

View File

@ -1,4 +1,4 @@
package io.github.javpower.milvus.plus.cache; package org.dromara.milvus.plus.cache;
import lombok.Data; import lombok.Data;

View File

@ -1,4 +1,4 @@
package io.github.javpower.milvus.plus.cache; package org.dromara.milvus.plus.cache;
import java.util.HashMap; import java.util.HashMap;
import java.util.Map; import java.util.Map;

View File

@ -1,14 +1,14 @@
package io.github.javpower.milvus.plus.converter; package org.dromara.milvus.plus.converter;
import com.google.common.collect.Lists; import com.google.common.collect.Lists;
import io.github.javpower.milvus.plus.annotation.*; import org.dromara.milvus.plus.annotation.*;
import io.github.javpower.milvus.plus.builder.CollectionSchemaBuilder; import org.dromara.milvus.plus.builder.CollectionSchemaBuilder;
import io.github.javpower.milvus.plus.cache.CollectionToPrimaryCache; import org.dromara.milvus.plus.cache.CollectionToPrimaryCache;
import io.github.javpower.milvus.plus.cache.ConversionCache; import org.dromara.milvus.plus.cache.ConversionCache;
import io.github.javpower.milvus.plus.cache.MilvusCache; import org.dromara.milvus.plus.cache.MilvusCache;
import io.github.javpower.milvus.plus.cache.PropertyCache; import org.dromara.milvus.plus.cache.PropertyCache;
import io.github.javpower.milvus.plus.model.MilvusEntity; import org.dromara.milvus.plus.model.MilvusEntity;
import io.milvus.v2.client.MilvusClientV2; import io.milvus.v2.client.MilvusClientV2;
import io.milvus.v2.common.IndexParam; import io.milvus.v2.common.IndexParam;
import io.milvus.v2.service.collection.request.AddFieldReq; import io.milvus.v2.service.collection.request.AddFieldReq;

View File

@ -1,14 +1,14 @@
package io.github.javpower.milvus.plus.converter; package org.dromara.milvus.plus.converter;
import com.fasterxml.jackson.databind.ObjectMapper; import com.fasterxml.jackson.databind.ObjectMapper;
import io.github.javpower.milvus.plus.cache.ConversionCache;
import io.github.javpower.milvus.plus.cache.MilvusCache;
import io.github.javpower.milvus.plus.cache.PropertyCache;
import io.github.javpower.milvus.plus.model.vo.MilvusResp;
import io.github.javpower.milvus.plus.model.vo.MilvusResult;
import io.milvus.v2.service.vector.response.GetResp; import io.milvus.v2.service.vector.response.GetResp;
import io.milvus.v2.service.vector.response.QueryResp; import io.milvus.v2.service.vector.response.QueryResp;
import io.milvus.v2.service.vector.response.SearchResp; import io.milvus.v2.service.vector.response.SearchResp;
import org.dromara.milvus.plus.cache.ConversionCache;
import org.dromara.milvus.plus.cache.MilvusCache;
import org.dromara.milvus.plus.cache.PropertyCache;
import org.dromara.milvus.plus.model.vo.MilvusResp;
import org.dromara.milvus.plus.model.vo.MilvusResult;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.HashMap; import java.util.HashMap;

View File

@ -1,8 +1,8 @@
package io.github.javpower.milvus.plus.core; package org.dromara.milvus.plus.core;
import io.github.javpower.milvus.plus.annotation.MilvusField; import org.dromara.milvus.plus.annotation.MilvusField;
import io.github.javpower.milvus.plus.cache.ConversionCache; import org.dromara.milvus.plus.cache.ConversionCache;
import io.github.javpower.milvus.plus.cache.MilvusCache; import org.dromara.milvus.plus.cache.MilvusCache;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import java.io.Serializable; import java.io.Serializable;

View File

@ -1,4 +1,4 @@
package io.github.javpower.milvus.plus.core.conditions; package org.dromara.milvus.plus.core.conditions;
import lombok.Data; import lombok.Data;

View File

@ -1,6 +1,6 @@
package io.github.javpower.milvus.plus.core.conditions; package org.dromara.milvus.plus.core.conditions;
import io.github.javpower.milvus.plus.core.FieldFunction; import org.dromara.milvus.plus.core.FieldFunction;
import java.lang.reflect.Field; import java.lang.reflect.Field;
import java.util.ArrayList; import java.util.ArrayList;

View File

@ -1,9 +1,9 @@
package io.github.javpower.milvus.plus.core.conditions; package org.dromara.milvus.plus.core.conditions;
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
import io.github.javpower.milvus.plus.cache.ConversionCache; import org.dromara.milvus.plus.cache.ConversionCache;
import io.github.javpower.milvus.plus.core.FieldFunction; import org.dromara.milvus.plus.core.FieldFunction;
import io.github.javpower.milvus.plus.model.vo.MilvusResp; import org.dromara.milvus.plus.model.vo.MilvusResp;
import io.milvus.exception.MilvusException; import io.milvus.exception.MilvusException;
import io.milvus.v2.client.MilvusClientV2; import io.milvus.v2.client.MilvusClientV2;
import io.milvus.v2.service.vector.request.DeleteReq; import io.milvus.v2.service.vector.request.DeleteReq;

View File

@ -1,11 +1,11 @@
package io.github.javpower.milvus.plus.core.conditions; package org.dromara.milvus.plus.core.conditions;
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import io.github.javpower.milvus.plus.cache.ConversionCache; import org.dromara.milvus.plus.cache.ConversionCache;
import io.github.javpower.milvus.plus.cache.PropertyCache; import org.dromara.milvus.plus.cache.PropertyCache;
import io.github.javpower.milvus.plus.core.FieldFunction; import org.dromara.milvus.plus.core.FieldFunction;
import io.github.javpower.milvus.plus.model.vo.MilvusResp; import org.dromara.milvus.plus.model.vo.MilvusResp;
import io.milvus.exception.MilvusException; import io.milvus.exception.MilvusException;
import io.milvus.v2.client.MilvusClientV2; import io.milvus.v2.client.MilvusClientV2;
import io.milvus.v2.service.vector.request.InsertReq; import io.milvus.v2.service.vector.request.InsertReq;

View File

@ -1,11 +1,11 @@
package io.github.javpower.milvus.plus.core.conditions; package org.dromara.milvus.plus.core.conditions;
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
import io.github.javpower.milvus.plus.cache.ConversionCache; import org.dromara.milvus.plus.cache.ConversionCache;
import io.github.javpower.milvus.plus.converter.SearchRespConverter; import org.dromara.milvus.plus.converter.SearchRespConverter;
import io.github.javpower.milvus.plus.core.FieldFunction; import org.dromara.milvus.plus.core.FieldFunction;
import io.github.javpower.milvus.plus.model.vo.MilvusResp; import org.dromara.milvus.plus.model.vo.MilvusResp;
import io.github.javpower.milvus.plus.model.vo.MilvusResult; import org.dromara.milvus.plus.model.vo.MilvusResult;
import io.milvus.exception.MilvusException; import io.milvus.exception.MilvusException;
import io.milvus.v2.client.MilvusClientV2; import io.milvus.v2.client.MilvusClientV2;
import io.milvus.v2.common.ConsistencyLevel; import io.milvus.v2.common.ConsistencyLevel;
@ -66,7 +66,7 @@ public class LambdaQueryWrapper<T> extends AbstractChainWrapper<T> implements Wr
} }
return this; return this;
} }
public LambdaQueryWrapper<T> partition(FieldFunction<T,?> ... partitionName){ public LambdaQueryWrapper<T> partition(FieldFunction<T,?>... partitionName){
for (FieldFunction<T, ?> p : partitionName) { for (FieldFunction<T, ?> p : partitionName) {
this.partitionNames.add(p.getFieldName(p)); this.partitionNames.add(p.getFieldName(p));
} }

View File

@ -1,12 +1,12 @@
package io.github.javpower.milvus.plus.core.conditions; package org.dromara.milvus.plus.core.conditions;
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import io.github.javpower.milvus.plus.cache.CollectionToPrimaryCache; import org.dromara.milvus.plus.cache.CollectionToPrimaryCache;
import io.github.javpower.milvus.plus.cache.ConversionCache; import org.dromara.milvus.plus.cache.ConversionCache;
import io.github.javpower.milvus.plus.cache.PropertyCache; import org.dromara.milvus.plus.cache.PropertyCache;
import io.github.javpower.milvus.plus.core.FieldFunction; import org.dromara.milvus.plus.core.FieldFunction;
import io.github.javpower.milvus.plus.model.vo.MilvusResp; import org.dromara.milvus.plus.model.vo.MilvusResp;
import io.milvus.exception.MilvusException; import io.milvus.exception.MilvusException;
import io.milvus.v2.client.MilvusClientV2; import io.milvus.v2.client.MilvusClientV2;
import io.milvus.v2.service.vector.request.SearchReq; import io.milvus.v2.service.vector.request.SearchReq;

View File

@ -1,6 +1,6 @@
package io.github.javpower.milvus.plus.core.conditions; package org.dromara.milvus.plus.core.conditions;
import io.github.javpower.milvus.plus.cache.ConversionCache; import org.dromara.milvus.plus.cache.ConversionCache;
import io.milvus.v2.client.MilvusClientV2; import io.milvus.v2.client.MilvusClientV2;
/** /**

View File

@ -1,17 +1,17 @@
package io.github.javpower.milvus.plus.core.mapper; package org.dromara.milvus.plus.core.mapper;
import io.github.javpower.milvus.plus.annotation.MilvusCollection;
import io.github.javpower.milvus.plus.cache.ConversionCache;
import io.github.javpower.milvus.plus.cache.MilvusCache;
import io.github.javpower.milvus.plus.core.conditions.*;
import io.github.javpower.milvus.plus.model.vo.MilvusResp;
import io.github.javpower.milvus.plus.model.vo.MilvusResult;
import io.github.javpower.milvus.plus.service.IAMService;
import io.milvus.v2.client.MilvusClientV2; import io.milvus.v2.client.MilvusClientV2;
import io.milvus.v2.service.vector.response.DeleteResp; import io.milvus.v2.service.vector.response.DeleteResp;
import io.milvus.v2.service.vector.response.InsertResp; import io.milvus.v2.service.vector.response.InsertResp;
import io.milvus.v2.service.vector.response.UpsertResp; import io.milvus.v2.service.vector.response.UpsertResp;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.dromara.milvus.plus.annotation.MilvusCollection;
import org.dromara.milvus.plus.cache.ConversionCache;
import org.dromara.milvus.plus.cache.MilvusCache;
import org.dromara.milvus.plus.core.conditions.*;
import org.dromara.milvus.plus.model.vo.MilvusResp;
import org.dromara.milvus.plus.model.vo.MilvusResult;
import org.dromara.milvus.plus.service.IAMService;
import java.io.Serializable; import java.io.Serializable;
import java.lang.reflect.ParameterizedType; import java.lang.reflect.ParameterizedType;

View File

@ -1,4 +1,4 @@
package io.github.javpower.milvus.plus.model; package org.dromara.milvus.plus.model;
import io.milvus.v2.common.IndexParam; import io.milvus.v2.common.IndexParam;
import io.milvus.v2.service.collection.request.AddFieldReq; import io.milvus.v2.service.collection.request.AddFieldReq;

View File

@ -1,4 +1,4 @@
package io.github.javpower.milvus.plus.model; package org.dromara.milvus.plus.model;
import io.milvus.v2.common.DataType; import io.milvus.v2.common.DataType;
import io.milvus.v2.service.collection.request.AddFieldReq; import io.milvus.v2.service.collection.request.AddFieldReq;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;

View File

@ -1,4 +1,4 @@
package io.github.javpower.milvus.plus.model; package org.dromara.milvus.plus.model;
import lombok.Data; import lombok.Data;

View File

@ -1,4 +1,4 @@
package io.github.javpower.milvus.plus.model.vo; package org.dromara.milvus.plus.model.vo;
import lombok.Data; import lombok.Data;
/** /**

View File

@ -1,4 +1,4 @@
package io.github.javpower.milvus.plus.model.vo; package org.dromara.milvus.plus.model.vo;
import lombok.Data; import lombok.Data;
/** /**

View File

@ -1,8 +1,8 @@
package io.github.javpower.milvus.plus.service; package org.dromara.milvus.plus.service;
import io.github.javpower.milvus.plus.annotation.MilvusCollection; import org.dromara.milvus.plus.annotation.MilvusCollection;
import io.github.javpower.milvus.plus.cache.CollectionToPrimaryCache; import org.dromara.milvus.plus.cache.CollectionToPrimaryCache;
import io.github.javpower.milvus.plus.model.MilvusProperties; import org.dromara.milvus.plus.model.MilvusProperties;
import io.milvus.v2.client.ConnectConfig; import io.milvus.v2.client.ConnectConfig;
import io.milvus.v2.client.MilvusClientV2; import io.milvus.v2.client.MilvusClientV2;
import io.milvus.v2.service.collection.request.ReleaseCollectionReq; import io.milvus.v2.service.collection.request.ReleaseCollectionReq;

View File

@ -1,4 +1,4 @@
package io.github.javpower.milvus.plus.service; package org.dromara.milvus.plus.service;
import io.milvus.v2.client.MilvusClientV2; import io.milvus.v2.client.MilvusClientV2;
import io.milvus.v2.service.rbac.request.*; import io.milvus.v2.service.rbac.request.*;

View File

@ -1,7 +1,7 @@
package io.github.javpower.milvus.plus.service; package org.dromara.milvus.plus.service;
import io.github.javpower.milvus.plus.converter.MilvusConverter; import org.dromara.milvus.plus.converter.MilvusConverter;
import io.github.javpower.milvus.plus.model.MilvusEntity; import org.dromara.milvus.plus.model.MilvusEntity;
import io.milvus.exception.MilvusException; import io.milvus.exception.MilvusException;
import io.milvus.v2.client.MilvusClientV2; import io.milvus.v2.client.MilvusClientV2;
import io.milvus.v2.service.collection.request.HasCollectionReq; import io.milvus.v2.service.collection.request.HasCollectionReq;

View File

@ -1,4 +1,4 @@
package io.github.javpower.milvus.plus.service; package org.dromara.milvus.plus.service;
import io.milvus.v2.client.MilvusClientV2; import io.milvus.v2.client.MilvusClientV2;

View File

@ -0,0 +1,12 @@
package org.dromara.milvus.plus.service.impl;
import org.dromara.milvus.plus.model.MilvusProperties;
import org.dromara.milvus.plus.service.AbstractMilvusClientBuilder;
public class MilvusClientBuild extends AbstractMilvusClientBuilder {
public MilvusClientBuild(MilvusProperties properties) {
super.setProperties(properties);
}
}

View File

@ -2,7 +2,7 @@
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"> xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
<groupId>io.github.javpower</groupId> <groupId>org.dromara</groupId>
<artifactId>milvus-plus-parent</artifactId> <artifactId>milvus-plus-parent</artifactId>
<version>${revision}</version> <version>${revision}</version>
<packaging>pom</packaging> <packaging>pom</packaging>
@ -49,17 +49,17 @@
<dependencyManagement> <dependencyManagement>
<dependencies> <dependencies>
<dependency> <dependency>
<groupId>io.github.javpower</groupId> <groupId>org.dromara</groupId>
<artifactId>milvus-plus-core</artifactId> <artifactId>milvus-plus-core</artifactId>
<version>${revision}</version> <version>${revision}</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>io.github.javpower</groupId> <groupId>org.dromara</groupId>
<artifactId>milvus-plus-boot-starter</artifactId> <artifactId>milvus-plus-boot-starter</artifactId>
<version>${revision}</version> <version>${revision}</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>io.github.javpower</groupId> <groupId>org.dromara</groupId>
<artifactId>milvus-plus-solon-plugin</artifactId> <artifactId>milvus-plus-solon-plugin</artifactId>
<version>${revision}</version> <version>${revision}</version>
</dependency> </dependency>

View File

@ -4,7 +4,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
<parent> <parent>
<groupId>io.github.javpower</groupId> <groupId>org.dromara</groupId>
<artifactId>milvus-plus-parent</artifactId> <artifactId>milvus-plus-parent</artifactId>
<version>${revision}</version> <version>${revision}</version>
<relativePath>../milvus-plus-parent/pom.xml</relativePath> <relativePath>../milvus-plus-parent/pom.xml</relativePath>
@ -15,7 +15,7 @@
<dependencies> <dependencies>
<dependency> <dependency>
<groupId>io.github.javpower</groupId> <groupId>org.dromara</groupId>
<artifactId>milvus-plus-core</artifactId> <artifactId>milvus-plus-core</artifactId>
</dependency> </dependency>

View File

@ -1,7 +1,7 @@
package io.github.javpower.solon; package org.dromara.solon;
import io.github.javpower.solon.entity.MilvusProperties; import org.dromara.solon.entity.MilvusProperties;
import io.github.javpower.solon.service.MilvusInit; import org.dromara.solon.service.MilvusInit;
import org.noear.solon.core.AppContext; import org.noear.solon.core.AppContext;
import org.noear.solon.core.Plugin; import org.noear.solon.core.Plugin;

View File

@ -1,4 +1,4 @@
package io.github.javpower.solon.entity; package org.dromara.solon.entity;
import lombok.Data; import lombok.Data;
import org.noear.solon.annotation.Configuration; import org.noear.solon.annotation.Configuration;

View File

@ -1,6 +1,6 @@
package io.github.javpower.solon.mapper; package org.dromara.solon.mapper;
import io.github.javpower.milvus.plus.core.mapper.BaseMilvusMapper; import org.dromara.milvus.plus.core.mapper.BaseMilvusMapper;
import io.milvus.v2.client.MilvusClientV2; import io.milvus.v2.client.MilvusClientV2;
import org.noear.solon.Solon; import org.noear.solon.Solon;

View File

@ -1,7 +1,7 @@
package io.github.javpower.solon.service; package org.dromara.solon.service;
import io.github.javpower.milvus.plus.service.AbstractMilvusClientBuilder; import org.dromara.milvus.plus.service.AbstractMilvusClientBuilder;
import io.github.javpower.solon.entity.MilvusProperties; import org.dromara.solon.entity.MilvusProperties;
import io.milvus.v2.client.MilvusClientV2; import io.milvus.v2.client.MilvusClientV2;
import org.noear.solon.annotation.*; import org.noear.solon.annotation.*;
import org.noear.solon.core.bean.LifecycleBean; import org.noear.solon.core.bean.LifecycleBean;
@ -13,7 +13,7 @@ public class MilvusInit extends AbstractMilvusClientBuilder implements Lifecycle
//see https://solon.noear.org/article/324 //see https://solon.noear.org/article/324
@Bean @Bean
public MilvusClientV2 init(MilvusProperties milvusProperties) { public MilvusClientV2 init(MilvusProperties milvusProperties) {
io.github.javpower.milvus.plus.model.MilvusProperties milvusProperties1 = new io.github.javpower.milvus.plus.model.MilvusProperties(); org.dromara.milvus.plus.model.MilvusProperties milvusProperties1 = new org.dromara.milvus.plus.model.MilvusProperties();
BeanUtils.copyProperties(milvusProperties, milvusProperties1); BeanUtils.copyProperties(milvusProperties, milvusProperties1);
super.setProperties(milvusProperties1); super.setProperties(milvusProperties1);
super.initialize(); super.initialize();

View File

@ -1,2 +1,2 @@
solon.plugin=io.github.javpower.solon.XPlugin solon.plugin=org.dromara.solon.XPlugin
solon.plugin.priority=1 solon.plugin.priority=1

View File

@ -11,7 +11,7 @@
<relativePath /> <relativePath />
</parent> </parent>
<groupId>io.github.javpower</groupId> <groupId>org.dromara</groupId>
<artifactId>milvus-solon-demo</artifactId> <artifactId>milvus-solon-demo</artifactId>
<version>1.0</version> <version>1.0</version>
@ -26,7 +26,7 @@
<dependencies> <dependencies>
<dependency> <dependency>
<groupId>io.github.javpower</groupId> <groupId>org.dromara</groupId>
<artifactId>milvus-plus-solon-plugin</artifactId> <artifactId>milvus-plus-solon-plugin</artifactId>
<version>2.4.0-SNAPSHOT</version> <version>2.4.0-SNAPSHOT</version>
</dependency> </dependency>

View File

@ -1,11 +0,0 @@
package io.github.javpower.solon.test.test;
import io.github.javpower.solon.mapper.MilvusMapper;
import io.github.javpower.solon.test.model.Face;
import org.noear.solon.annotation.Component;
@Component
public class FaceMilvusMapper extends MilvusMapper<Face> {
}

View File

@ -1,4 +1,4 @@
package io.github.javpower.solon; package org.dromara.solon;
import org.noear.solon.Solon; import org.noear.solon.Solon;
import org.noear.solon.annotation.SolonMain; import org.noear.solon.annotation.SolonMain;

View File

@ -1,10 +1,10 @@
package io.github.javpower.solon; package org.dromara.solon;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import io.github.javpower.milvus.plus.model.vo.MilvusResp; import org.dromara.milvus.plus.model.vo.MilvusResp;
import io.github.javpower.milvus.plus.model.vo.MilvusResult; import org.dromara.milvus.plus.model.vo.MilvusResult;
import io.github.javpower.solon.test.model.Face; import org.dromara.solon.test.model.Face;
import io.github.javpower.solon.test.test.FaceMilvusMapper; import org.dromara.solon.test.test.FaceMilvusMapper;
import io.milvus.v2.service.vector.response.DeleteResp; import io.milvus.v2.service.vector.response.DeleteResp;
import io.milvus.v2.service.vector.response.InsertResp; import io.milvus.v2.service.vector.response.InsertResp;
import io.milvus.v2.service.vector.response.UpsertResp; import io.milvus.v2.service.vector.response.UpsertResp;
@ -25,6 +25,11 @@ public class DemoController {
@Mapping("/test") @Mapping("/test")
@Get @Get
public void hello() { public void hello() {
}
private void face(){
Face face=new Face(); Face face=new Face();
List<Float> vector = new ArrayList<>(); List<Float> vector = new ArrayList<>();
for (int i = 0; i < 128; i++) { for (int i = 0; i < 128; i++) {
@ -74,6 +79,5 @@ public class DemoController {
//查询 //查询
MilvusResp<List<MilvusResult<Face>>> query4 = mapper.getById(1L);log.info("query--{}", JSONObject.toJSONString(query4)); MilvusResp<List<MilvusResult<Face>>> query4 = mapper.getById(1L);log.info("query--{}", JSONObject.toJSONString(query4));
} }
} }

View File

@ -1,9 +1,9 @@
package io.github.javpower.solon.test.model; package org.dromara.solon.test.model;
import io.github.javpower.milvus.plus.annotation.ExtraParam; import org.dromara.milvus.plus.annotation.ExtraParam;
import io.github.javpower.milvus.plus.annotation.MilvusCollection; import org.dromara.milvus.plus.annotation.MilvusCollection;
import io.github.javpower.milvus.plus.annotation.MilvusField; import org.dromara.milvus.plus.annotation.MilvusField;
import io.github.javpower.milvus.plus.annotation.MilvusIndex; import org.dromara.milvus.plus.annotation.MilvusIndex;
import io.milvus.v2.common.DataType; import io.milvus.v2.common.DataType;
import io.milvus.v2.common.IndexParam; import io.milvus.v2.common.IndexParam;
import lombok.Data; import lombok.Data;

View File

@ -0,0 +1,11 @@
package org.dromara.solon.test.test;
import org.dromara.solon.mapper.MilvusMapper;
import org.dromara.solon.test.model.Face;
import org.noear.solon.annotation.Component;
@Component
public class FaceMilvusMapper extends MilvusMapper<Face> {
}

View File

@ -10,4 +10,4 @@ milvus:
token: xxxx token: xxxx
enable: true enable: true
packages: packages:
- io.github.javpower.solon.test.model - org.dromara.solon.test.model

View File

@ -2,7 +2,7 @@
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"> xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
<groupId>io.github.javpower</groupId> <groupId>org.dromara</groupId>
<artifactId>milvus-spring-demo</artifactId> <artifactId>milvus-spring-demo</artifactId>
<version>0.0.1-SNAPSHOT</version> <version>0.0.1-SNAPSHOT</version>
<name>milvus-spring-demo</name> <name>milvus-spring-demo</name>
@ -19,7 +19,7 @@
<artifactId>spring-boot-starter</artifactId> <artifactId>spring-boot-starter</artifactId>
</dependency> </dependency>
<dependency> <dependency>
<groupId>io.github.javpower</groupId> <groupId>org.dromara</groupId>
<artifactId>milvus-plus-boot-starter</artifactId> <artifactId>milvus-plus-boot-starter</artifactId>
<version>2.4.0-SNAPSHOT</version> <version>2.4.0-SNAPSHOT</version>
</dependency> </dependency>
@ -53,7 +53,7 @@
<artifactId>spring-boot-maven-plugin</artifactId> <artifactId>spring-boot-maven-plugin</artifactId>
<version>${spring-boot.version}</version> <version>${spring-boot.version}</version>
<configuration> <configuration>
<mainClass>io.github.javpower.milvus.demo.MilvusDemoApplication</mainClass> <mainClass>org.dromara.milvus.demo.MilvusDemoApplication</mainClass>
<skip>true</skip> <skip>true</skip>
</configuration> </configuration>
<executions> <executions>

View File

@ -1,10 +0,0 @@
package io.github.javpower.milvus.demo.test;
import io.github.javpower.milvus.demo.model.Face;
import io.github.javpower.milvus.plus.mapper.MilvusMapper;
import org.springframework.stereotype.Component;
@Component
public class FaceMilvusMapper extends MilvusMapper<Face> {
}

View File

@ -1,16 +1,12 @@
package io.github.javpower.milvus.demo; package org.dromara.milvus.demo;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import io.github.javpower.milvus.demo.model.Face; import org.dromara.milvus.demo.model.Face;
import io.github.javpower.milvus.demo.test.FaceMilvusMapper; import org.dromara.milvus.demo.test.FaceMilvusMapper;
import io.github.javpower.milvus.demo.test.QaMilvusMapper; import org.dromara.milvus.plus.model.vo.MilvusResp;
import io.github.javpower.milvus.plus.model.vo.MilvusResp; import org.dromara.milvus.plus.model.vo.MilvusResult;
import io.github.javpower.milvus.plus.model.vo.MilvusResult;
import io.milvus.v2.service.vector.response.DeleteResp;
import io.milvus.v2.service.vector.response.InsertResp; import io.milvus.v2.service.vector.response.InsertResp;
import io.milvus.v2.service.vector.response.UpsertResp;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.ApplicationArguments; import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner; import org.springframework.boot.ApplicationRunner;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
@ -22,8 +18,6 @@ import java.util.List;
@Slf4j @Slf4j
public class ApplicationRunnerTest implements ApplicationRunner { public class ApplicationRunnerTest implements ApplicationRunner {
private final FaceMilvusMapper mapper; private final FaceMilvusMapper mapper;
@Autowired
private QaMilvusMapper qaMilvusMapper;
public ApplicationRunnerTest(FaceMilvusMapper mapper) { public ApplicationRunnerTest(FaceMilvusMapper mapper) {
this.mapper = mapper; this.mapper = mapper;
@ -51,6 +45,11 @@ public class ApplicationRunnerTest implements ApplicationRunner {
vector1.add((float) (Math.random() * 100)); // 这里仅作为示例使用随机数 vector1.add((float) (Math.random() * 100)); // 这里仅作为示例使用随机数
} }
face1.setFaceVector(vector1); face1.setFaceVector(vector1);
if(i%2==0){
face1.setPersonName("张三"+i);
}else {
face1.setPersonName("李四"+i);
}
faces.add(face1); faces.add(face1);
} }
MilvusResp<InsertResp> insert = mapper.insertWrapper().partition("face_001").insert(faces.toArray(new Face[0])); MilvusResp<InsertResp> insert = mapper.insertWrapper().partition("face_001").insert(faces.toArray(new Face[0]));
@ -62,28 +61,16 @@ public class ApplicationRunnerTest implements ApplicationRunner {
//向量查询 //向量查询
MilvusResp<List<MilvusResult<Face>>> query1 = mapper.queryWrapper() MilvusResp<List<MilvusResult<Face>>> query1 = mapper.queryWrapper()
.vector(Face::getFaceVector, vector) .vector(Face::getFaceVector, vector)
.ne(Face::getPersonId, 1L) .like(Face::getPersonName, "张三")
.topK(3) .topK(3)
.query(); .query();
log.info("向量查询 query--queryWrapper---{}", JSONObject.toJSONString(query1)); log.info("向量查询 query--queryWrapper---{}", JSONObject.toJSONString(query1));
//标量查询 //标量查询
MilvusResp<List<MilvusResult<Face>>> query2 = mapper.queryWrapper() MilvusResp<List<MilvusResult<Face>>> query2 = mapper.queryWrapper()
.eq(Face::getPersonId, 2L) .eq(Face::getPersonId, 2L)
.topK(3) .limit(3l)
.query(); .query();
log.info("标量查询 query--queryWrapper---{}", JSONObject.toJSONString(query2)); log.info("标量查询 query--queryWrapper---{}", JSONObject.toJSONString(query2));
//更新
vector.clear();
for (int i = 0; i < 128; i++) {
vector.add((float) (Math.random() * 100)); // 这里仅作为示例使用随机数
}
MilvusResp<UpsertResp> update = mapper.updateById(face);log.info("update--{}", JSONObject.toJSONString(update));
//id查询
MilvusResp<List<MilvusResult<Face>>> query3 = mapper.getById(1L);log.info("query--getById---{}", JSONObject.toJSONString(query3));
//删除
MilvusResp<DeleteResp> remove = mapper.removeById(1L);log.info("remove--{}", JSONObject.toJSONString(remove));
//查询
MilvusResp<List<MilvusResult<Face>>> query4 = mapper.getById(1L);log.info("query--{}", JSONObject.toJSONString(query4));
} }
} }

View File

@ -1,10 +1,7 @@
package io.github.javpower.milvus.demo; package org.dromara.milvus.demo;
import org.springframework.boot.SpringApplication; import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.context.properties.ConfigurationPropertiesScan;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.stereotype.Component;
@SpringBootApplication @SpringBootApplication
public class MilvusDemoApplication { public class MilvusDemoApplication {

View File

@ -1,9 +1,9 @@
package io.github.javpower.milvus.demo.model; package org.dromara.milvus.demo.model;
import io.github.javpower.milvus.plus.annotation.*;
import io.milvus.v2.common.DataType; import io.milvus.v2.common.DataType;
import io.milvus.v2.common.IndexParam; import io.milvus.v2.common.IndexParam;
import lombok.Data; import lombok.Data;
import org.dromara.milvus.plus.annotation.*;
import java.util.List; import java.util.List;
@ -19,6 +19,12 @@ public class Face {
) )
private Long personId; // 人员的唯一标识符 private Long personId; // 人员的唯一标识符
@MilvusField(
name = "person_name",
dataType = DataType.VarChar
)
private String personName; // 人员姓名
@MilvusField( @MilvusField(
name = "face_vector", // 字段名称 name = "face_vector", // 字段名称
dataType = DataType.FloatVector, // 数据类型为浮点型向量 dataType = DataType.FloatVector, // 数据类型为浮点型向量

View File

@ -0,0 +1,10 @@
package org.dromara.milvus.demo.test;
import org.dromara.milvus.demo.model.Face;
import org.dromara.milvus.plus.mapper.MilvusMapper;
import org.springframework.stereotype.Component;
@Component
public class FaceMilvusMapper extends MilvusMapper<Face> {
}

View File

@ -2,7 +2,7 @@
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"> xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
<groupId>io.github.javpower</groupId> <groupId>org.dromara</groupId>
<artifactId>MilvusPlus</artifactId> <artifactId>MilvusPlus</artifactId>
<version>0.0.1-SNAPSHOT</version> <version>0.0.1-SNAPSHOT</version>
<name>milvus-plus</name> <name>milvus-plus</name>