String data = StreamUtils.copyToString(new FileInputStream("/home/sc/桌面/entimport.csv"), StandardCharsets.UTF_8);
String[] split = data.split("\n");
System.out.println(split.length);
StringBuilder sb = new StringBuilder();
String date = DateUtils.toStr(new Date(), "yyyy-MM-dd HH:mm:ss");
for (String item : split) {
String[] split1 = item.split(",");
///System.out.println(":" + split1[5] + " " + getStringU(split1[5]));
//sb.append("INSERT INTO public.tb_user_related_company (user_id, nsrsbh, qymc, is_bund, created_ts, last_modified_ts, city_code, area_code, \"location\", legal_name, legal_phone, legal_id, company_four_status, legal_three_status, province_code, scf_province, scf_city, scf_district, scf_platform, authority, certify_type, additional, approval_id, approval_status, remark, approval_ts, revenue, subject, park, department) VALUES((select tu.id from tb_user tu where tu.phone='" + getStringU(split1[7]) + "'), '" + getStringU(split1[3]) + "', '" + getStringU(split1[2]) + "', true, '" + date + "', '" + date + "', '500118', null, '" + getStringU(split1[8]) + "', '" + getStringU(split1[4]) + "', '" + ScAESUtil.encrypt(getStringU(split1[6])) + "', '" + ScAESUtil.encrypt(getStringU(split1[5])) + "', true, true, '500000', '500000', '0', '0', '1001', NULL, 'FR', '{}'::jsonb::jsonb, NULL, 'PASSED', NULL, '" + date + "', NULL, 'QY', NULL, NULL)").append(";\n");
sb.append("INSERT INTO public.tb_user (created_ts, last_modified_ts, \"name\", phone, \"password\", email, logo, role_id, organization_id, creator_id, editor_id, user_status, push_phone, city, district, \"type\", tax_number, level_id, depart_id, qrcode_url, service_area, develop_user_id, creator_department_id, region_list, auth_status, company_name, is_test, xnw_uuid, \"source\", user_no, mark_img, recommendation_code, scf_province, scf_city, scf_district, scf_platform, login_time, sex, birthday, background_url, area_code, detail_addr, person_lables, person_introduce, contract_phone, login_name) VALUES(now(), now(), '"+getStringU(split1[3])+"', '"+getStringU(split1[3])+"', '"+securityService.generateHashAndSalt(PasswordUtils.generateDefaultPassword(getStringU(split1[3])))+"', '', NULL, 4, NULL, NULL, NULL, 'ACTIVE', NULL, NULL, NULL, 'PHONE', NULL, NULL, NULL, NULL, '{}', NULL, NULL, '{}', 'UNAUTHORIZED', NULL, false, NULL, 'PC', NULL, NULL, NULL, '500000', '0', '0', '1001', now(), NULL, NULL, NULL, NULL, NULL, '{}', NULL, NULL, '"+getStringU(split1[3])+"')").append(";\n");
}
StreamUtils.copy(sb.toString().getBytes(), new FileOutputStream("/home/sc/桌面/entimport.sql"));
System.out.println("完成");
版权归属:
王小木人个人技术文章记录
许可协议:
本文使用《署名-非商业性使用-相同方式共享 4.0 国际 (CC BY-NC-SA 4.0)》协议授权
评论区