【MySQL集】——Java程序连接MySQL集
【MySQL集】——Java程序连接MySQL集
上篇简介了怎样，这⾥⽤⼀个实现注冊功能的⼩Demo通过jdbc的⽅式连接到MySQL集中。
外部程序想要远程连接到mysql集，还须要做的⼀个操作就是设置sql节点的mysql能够被远程连接。
详细操作为：
mysql> grant all privileges on MySQL_Cluster_Test.* to root@'%' identified by '';
mysql> flush privileges;
表⽰将MySQL_Cluster_Test这个数据库中全部的表授权给全部机器，登录名为root。password为空。假设仅仅指定某台机器能够连接此数据节点。那把“%”换成对应IP就可以。
UserDAO代码：
public class UserDAO{
大方丝巾的系法视频
/**赵本山喜剧电影大全
* 加⼊⽤户
* @param name username
* @param age ⽤户年龄
* @return
*/
public boolean AddUser(String name,int age){
boolean result=false;//返回值默觉得false
Connection conn=null;//创建数据库连接对象Connection
PreparedStatement pstmt=null;//创建预处理对象PreparedStatement
try {
//注冊驱动
Class.forName("sql.jdbc.Driver");
/
/建⽴连接
Connection("jdbc:mysql://192.168.25.48:3306/MySQL_Cluster_Test","root","");
}catch (Exception e){
e.printStackTrace();
}
try{
String sql="insert into T_User (Name,Age) values(?,?)";
pstmt=conn.prepareStatement(sql);
pstmt.setString(1, name);
pstmt.setInt(2, age);
int uteUpdate();  //更新数据库并返回受影响⾏数
if(count>0){
result=true;
}
}catch(Exception e){
e.printStackTrace();
}
奇迹1.03return result;
}
/**
* 查询全部⽤户
* @return List<User>
*/
public List<User> QueryAllUsers(){
List<User> userList=new ArrayList<User>();
Connection conn=null;
Statement stmt=null;
try {
//注冊驱动
Class.forName("sql.jdbc.Driver");
//建⽴连接
Connection("jdbc:mysql://192.168.25.48:3306/MySQL_Cluster_Test","root","");
}catch (Exception e){
e.printStackTrace();
}
try {
String sql = "select * from T_User";
ateStatement();
ResultSet rs =uteQuery(sql);
()){
User tmpUser=new User();
tmpUser.String("Name"));
波斯狼酒是什么意思
tmpUser.Int("Age"));
userList.add(tmpUser);
}万足金
网络不稳定怎么办
} catch (SQLException e) {
e.printStackTrace();
}
return userList;
}
}
假设前⾯的MySQL集配置好的话，就能够实现多个server上公布的外部程序都能够共享、操作整个集中的数据。但此时的MySQL集还⽆法实现负载均衡和读写分离的效果，仅仅起到了数据备份的作⽤。
后⾯将继续研究怎样实现MySQL集的负载均衡和读写分离。
（以上仅仅是主要代码，假设须要整个项⽬，能够点击下载源代码）

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。