首先,我们需要在Spring Boot项目中配置PostgreSQL数据库连接。在application.properties文件中添加以下配置:

spring.datasource.url=jdbc:postgresql://localhost:5432/db_name
spring.datasource.username=username
spring.datasource.password=password
spring.jpa.properties.hibernate.dialect=org.hibernate.dialect.PostgreSQLDialect
spring.jpa.hibernate.ddl-auto=update

接下来,我们需要创建一个User实体类,用于映射sys.t__user表的字段。在User类中添加以下属性和相应的getter和setter方法:

@Entity
@Table(name = "sys.t__user")
public class User {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;
    
    @Column(name = "create_time")
    private Date createTime;
    
    @Column(name = "update_time")
    private Date updateTime;
    
    private String username;
    private String password;
    private String phone;
    private String city;
    
    @Column(name = "role_id")
    private Long roleId;
    
    @Column(name = "create_user")
    private String createUser;
    
    @Column(name = "update_user")
    private String updateUser;
    
    // getter and setter methods
}

然后,我们需要创建一个UserRepository接口,用于操作User实体类对应的表。在UserRepository接口中添加以下代码:

@Repository
public interface UserRepository extends JpaRepository<User, Long> {
}

接下来,我们需要创建一个UserService类,用于处理业务逻辑。在UserService类中添加以下代码:

@Service
public class UserService {
    @Autowired
    private UserRepository userRepository;
    
    public void insertRandomData(int count) {
        Random random = new Random();
        
        for (int i = 0; i < count; i++) {
            User user = new User();
            user.setCreateTime(new Date());
            user.setUpdateTime(new Date());
            user.setUsername("user" + i);
            user.setPassword("password" + i);
            user.setPhone("phone" + i);
            user.setCity("city" + i);
            user.setRoleId(random.nextLong());
            user.setCreateUser("admin");
            user.setUpdateUser("admin");
            
            userRepository.save(user);
        }
    }
}

最后,我们可以在Spring Boot的启动类中调用UserService的insertRandomData方法来插入200w行随机数据。在启动类中添加以下代码:

@SpringBootApplication
public class Application implements CommandLineRunner {
    @Autowired
    private UserService userService;
    
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
    
    @Override
    public void run(String... args) throws Exception {
        userService.insertRandomData(2000000);
    }
}

以上就是使用Java语言、Spring Boot和Spring Cloud方式实现在PostgreSQL数据库中随机插入200w行数据的步骤

作为一个postgres数据库有一张syst__user表表中有create_timeupdate_timeidusernamepasswordphonecityrole_idcreate_userupdate_user字段使用java语言springboot+springclound方式ssm架构随机插入200w行数据

原文地址: http://www.cveoy.top/t/topic/hDVC 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录