在java中使用带有UDT的cassandra映射器

import com.datastax.oss.driver.api.mapper.annotations.Entity;
import com.datastax.oss.driver.api.mapper.annotations.Field;
import com.datastax.oss.driver.api.mapper.annotations.UDT;

@UDT
public class Address {
    @Field(name = "street")
    private String street;

    @Field(name = "city")
    private String city;

    // Getters and setters
}

import com.datastax.oss.driver.api.mapper.annotations.Entity;
import com.datastax.oss.driver.api.mapper.annotations.PartitionKey;
import com.datastax.oss.driver.api.mapper.annotations.Property;
import com.datastax.oss.driver.api.mapper.annotations.Table;

@Entity
@Table(name = "users")
public class User {
    @PartitionKey
    @Property(name = "id")
    private UUID id;

    @Property(name = "name")
    private String name;

    @Property(name = "address")
    private Address address;

    // Getters and setters
}

import com.datastax.oss.driver.api.mapper.annotations.Dao;
import com.datastax.oss.driver.api.mapper.annotations.Query;

@Dao
public interface UserDao {
    @Query("SELECT * FROM users WHERE id = :id")
    User findById(UUID id);

    @Query("INSERT INTO users (id, name, address) VALUES (:id, :name, :address)")
    void save(User user);

    // Other methods
}

import com.datastax.oss.driver.api.core.CqlSession;
import com.datastax.oss.driver.api.mapper.MapperBuilder;
import com.datastax.oss.driver.api.mapper.ObjectMapper;
import com.datastax.oss.driver.api.mapper.annotations.Mapper;

@Mapper
public interface UserMapper extends ObjectMapper<User> {
    static UserMapper builder(CqlSession session) {
        return new MapperBuilder<User>(session).build(UserMapper.class);
    }

    UserDao userDao();
}

import com.datastax.oss.driver.api.core.CqlSession;

public class MyApp {
    public static void main(String[] args) {
        CqlSession session = CqlSession.builder().build();
        UserMapper userMapper = UserMapper.builder(session);
        UserDao userDao = userMapper.userDao();

        UUID userId = UUID.randomUUID();
        User user = new User();
        user.setId(userId);
        user.setName("John Doe");

        Address address = new Address();
        address.setStreet("123 Main St");
        address.setCity("New York");
        user.setAddress(address);

        userDao.save(user);

        User retrievedUser = userDao.findById(userId);
        System.out.println(retrievedUser.getName()); // Output: John Doe

        session.close();
    }
}