java读写mysql数据库

A. Java mysql数据库多线程读写问题，谢谢！

设置conn.autocommit(false)
这样就不会存在自动提交 也就是说 你的操作还只是内存操作 别人看到的只能是没有变化的表 直到你循环完毕用conn.commit()

B. java读取MySQL数据库

在String
value
=
rs.getString("name");
之前要先rs.next();一下
你用这个来判断密码错误？
if(!rs.isBeforeFirst()){
JOptionPane.showMessageDialog(frame,
"Wrong
password!");
}
isBeforeFirst()
的意思是：获取光标是否位于此
ResultSet
对象的第一行之前。

C. musql分库分表后java如何读写

musql分库分表后java用Mybatis可以很方便的实现分库分表，比如有几个数据源，每个库对应一个数据源，然后配置好负责读写的路由和表的配置，保证读写的数据库一致性就可以了

D. 如何在Java程序中访问mysql数据库中的数据并进行简单的操作

/**
*获取数据库的连接
*@returnconn
*/
()throwsException{
	Stringurl="jdbc:mysql://10.10.35.188:3306/sgjwx";
	Stringuser="opermain";
	Stringpsw="opermain";
	Connectionconn=null;
	PreparedStatementpstm=null;
	ResultSetrs=null;
	Class.forName("com.mysql.jdbc.Driver");
if(null==conn){
try{
conn=DriverManager.getConnection(url,user,psw);
}catch(SQLExceptione){
System.out.println("获取失败");
thrownewRuntimeException(e);
}finally{
	closeResources(conn,pstm,rs);
}
}
returnconn;
}
/**
*释放资源
*@paramconn
*@parampstmt
*@paramrs
*/
(Connectionconn,PreparedStatementpstmt,ResultSetrs){
if(null!=rs){
try{
rs.close();
}catch(SQLExceptione){
e.printStackTrace();
thrownewRuntimeException(e);
}finally{
if(null!=pstmt){
try{
pstmt.close();
}catch(SQLExceptione){
e.printStackTrace();
thrownewRuntimeException(e);
}finally{
if(null!=conn){
try{
conn.close();
}catch(SQLExceptione){
e.printStackTrace();
thrownewRuntimeException(e);
}
}
}
}
}
}
}


//		//tuserrole执行插入
//		try{
//			Stringsql="insertintosys_userrole(roleid,userid)values(?,?)";
//		conn=getConnection();
//		conn.setAutoCommit(false);
//		PreparedStatementpstmt=(PreparedStatement)conn.prepareStatement(sql,Statement.RETURN_GENERATED_KEYS);//传入参数：Statement.RETURN_GENERATED_KEYS
//		pstmt.setInt(1,5);
//		pstmt.setInt(2,sid);
//		pstmt.executeUpdate();
//		ResultSetrs=pstmt.getGeneratedKeys();//获取结果
//		inta=-1;
//			if(rs.next()){
//				a=rs.getInt(1);//取得ID
//			}
//			System.out.println(a);
//		System.out.println("t_userrole执行成功");
//		conn.commit();
//		}catch(Exceptione){
//			e.printStackTrace();
//			System.out.println("执行失败");
//		}

E. java程序如何访问mysql数据库

Java连接MySql需要下载JDBC驱动MySQL-connector-java-5.0.5.zip。然后将其解压缩到任一目录。解压到D盘，然后将其目录下的MySQL-connector-java-5.0.5-bin.jar加到classpath里，具体如下：

“我的电脑”-> “属性” -> “高级” -> “环境变量”，在系统变量那里编辑classpath，将D:MySQL-connector-java-5.0.5MySQL-connector-java-5.0.5-bin.jar加到最后，在加这个字符串前要加“;”，以与前一个classpath区分开，然后确定。

packagehqs;
importjava.sql.*;
publicclassDataBasePractice{

publicstaticvoidmain(String[]args){
//声明Connection对象
Connectioncon;
//驱动程序名
Stringdriver="com.mysql.jdbc.Driver";
//URL指向要访问的数据库名mydata
Stringurl="jdbc:mysql://localhost:3306/mydata";
//MySQL配置时的用户名
Stringuser="root";
//MySQL配置时的密码
Stringpassword="root";
//遍历查询结果集
try{
//加载驱动程序
Class.forName(driver);
//1.getConnection()方法，连接MySQL数据库！！
con=DriverManager.getConnection(url,user,password);
if(!con.isClosed())
System.out.println("!");
//2.创建statement类对象，用来执行SQL语句！！
Statementstatement=con.createStatement();
//要执行的SQL语句
Stringsql="select*fromstudent";
//3.ResultSet类，用来存放获取的结果集！！
ResultSetrs=statement.executeQuery(sql);
System.out.println("-----------------");
System.out.println("执行结果如下所示:");
System.out.println("-----------------");
System.out.println("学号"+"	"+"姓名");
System.out.println("-----------------");

Stringname=null;
Stringid=null;
while(rs.next()){
//获取stuname这列数据
name=rs.getString("stuname");
//获取stuid这列数据
id=rs.getString("stuid");
//首先使用ISO-8859-1字符集将name解码为字节序列并将结果存储新的字节数组中。
//然后使用GB2312字符集解码指定的字节数组。
name=newString(name.getBytes("ISO-8859-1"),"gb2312");
//输出结果
System.out.println(id+"	"+name);
}
rs.close();
con.close();
}catch(ClassNotFoundExceptione){
//数据库驱动类异常处理
System.out.println("Sorry,can`tfindtheDriver!");
e.printStackTrace();
}catch(SQLExceptione){
//数据库连接失败异常处理
e.printStackTrace();
}catch(Exceptione){
//TODO:handleexception
e.printStackTrace();
}finally{
System.out.println("数据库数据成功获取！！");
}
}

}

F. 如何在Java程序中访问mysql数据库中的数据并进行简单的操作

创建一个javaProject，并输入如下java代码：

package link;import java.sql.*;/*** 使用JDBC连接数据库MySQL的过程* DataBase：fuck， table：person；* 使用myeclipse对mysql数据库进行增删改查的基本操作。*/public class JDBCTest {public static Connection getConnection() throws SQLException,java.lang.ClassNotFoundException{//第一步：加载MySQL的JDBC的驱动Class.forName("com.mysql.jdbc.Driver");//取得连接的url,能访问MySQL数据库的用户名,密码；jsj：数据库名String url = "jdbc:mysql://localhost:/fuck";String username = "root";String password = "";//第二步：创建与MySQL数据库的连接类的实例Connection con = DriverManager.getConnection(url, username, password);return con;}public static void main(String args[]) {try{//第三步：获取连接类实例con，用con创建Statement对象类实例 sql_statementConnection con = getConnection();Statement sql_statement = con.createStatement();//如果同名数据库存在，删除//sql_statement.executeUpdate("drop table if exists student");//执行了一个sql语句生成了一个名为student的表//sql_statement.executeUpdate("create table student (id int not null auto_increment, name varchar() not null default 'name', math int not null default , primary key (id) ); ");//向person表中插入数据sql_statement.executeUpdate("insert person values(, 'liying', )");sql_statement.executeUpdate("insert person values(, 'jiangshan', )");sql_statement.executeUpdate("insert person values(, 'wangjiawu', )");sql_statement.executeUpdate("insert person values(, 'changfeng', )");//第四步：执行查询，用ResultSet类的对象，返回查询的结果String query = "select * from person";ResultSet result = sql_statement.executeQuery(query);//显示数据中person表中的内容：System.out.println("person表中的数据如下:");System.out.println("------------------------");System.out.println("序号" + " " + "姓名" + " " + "分数");System.out.println("------------------------");//对获得的查询结果进行处理，对Result类的对象进行操作while (result.next()){int number = result.getInt("number");String name = result.getString("name");String mathsorce = result.getString("mathsorce");//取得数据库中的数据System.out.println(" " + number + " " + name + " " + mathsorce);}//关闭连接和声明sql_statement.close();con.close();} catch(java.lang.ClassNotFoundException e) {System.err.print("ClassNotFoundException");System.err.println(e.getMessage());} catch (SQLException ex) {System.err.println("SQLException: " + ex.getMessage());}}}

注意有几个地方是你需要修改的。

如下图中的url和账号，密码需要与你自己的相一致。

G. 怎么在java中读取mysql数据库

要看你是用框架还是传统的JDBC连接了，如果是传统的JDBC连接的话方法如下：

Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");//加载数据库驱动，不同数据库加载的驱动不一样，这个例子是sqlserver数据库
Stringurl="jdbc:sqlserver://127.0.0.1:1433;databaseName=testDB";//IP:端口;databaseName:数据库名
Stringsql="selectnamefromt_user";//sql查询语句
Connectioncon=DriverManager.getConnection(url,username,password);//url:
数据库连接串userName:数据库登录账号passWord：数据库登录密码
Statementstmt=con.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_READ_ONLY);
ResultSetrs=stmt.executeQuery(sql);
//用户对象集合
List<User>userList=newArrayList<User>();
while(rs.next()){
Useruser=newUser();
user.setName=rs.getString("name");
userList.add(user);
}

H. 如何在Java程序中访问mysql数据库中的数据并进行简单的操作

一、使用工具：java语言、Myeclipse。

二、操作步骤：

1、第一步：加载MySQL的JDBC的驱动

I. java怎样将读取数据写入数据库

Java可以使用JDBC对数据库进行读写。JDBC访问一般分为如下流程：

一、加载JDBC驱动程序：
在连接数据库之前，首先要加载想要连接的数据库的驱动到JVM（Java虚拟机）， 这通过java.lang.Class类的静态方法forName(String className)实现。

例如：

try{

//加载MySql的驱动类

Class.forName("com.mysql.jdbc.Driver") ;

}catch(ClassNotFoundException e){

System.out.println("找不到驱动程序类 ，加载驱动失败！");

e.printStackTrace() ;
}

成功加载后，会将Driver类的实例注册到DriverManager类中。

二、提供JDBC连接的URL 连接URL定义了连接数据库时的协议、子协议、数据源标识。

书写形式：协议：子协议：数据源标识 协议：在JDBC中总是以jdbc开始

子协议：是桥连接的驱动程序或是数据库管理系统名称。

数据源标识：标记找到数据库来源的地址与连接端口。

例如：（MySql的连接URL）

jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=gbk

useUnicode=true：表示使用Unicode字符集。如果characterEncoding设置为

gb2312或GBK，本参数必须设置为true 。characterEncoding=gbk：字符编码方式。

三、创建数据库的连接

要连接数据库，需要向java.sql.DriverManager请求并获得Connection对象，该对象就代表一个数据库的连接。

使用DriverManager的getConnectin(String url,String username,String password )方法传入指定的欲连接的数据库的路径、数据库的用户名和密码来获得。

例如：
//连接MySql数据库，用户名和密码都是root

String url = "jdbc:mysql://localhost:3306/test" ;

String username = "root" ;

String password = "root" ;

try{

Connection con =
DriverManager.getConnection(url , username , password ) ;
}catch(SQLException se){

System.out.println("数据库连接失败！");
se.printStackTrace() ;
}

四、创建一个Statement
要执行SQL语句，必须获得java.sql.Statement实例，Statement实例分为以下3种类型：

1、执行静态SQL语句。通常通过Statement实例实现。

2、执行动态SQL语句。通常通过PreparedStatement实例实现。

3、执行数据库存储过程。通常通过CallableStatement实例实现。

具体的实现方式：
Statement stmt = con.createStatement() ;

PreparedStatement pstmt = con.prepareStatement(sql) ;

CallableStatement cstmt = con.prepareCall("{CALL demoSp(? , ?)}") ;

五、执行SQL语句

Statement接口提供了三种执行SQL语句的方法：executeQuery 、executeUpdate和execute

1、ResultSet executeQuery(String sqlString)：执行查询数据库的SQL语句，返回一个结果集（ResultSet）对象。

2、int executeUpdate(String sqlString)：用于执行INSERT、UPDATE或DELETE语句以及SQL DDL语句，如：CREATE TABLE和DROP TABLE等

3、execute(sqlString):用于执行返回多个结果集、多个更新计数或二者组合的语句。
具体实现的代码：

ResultSet rs = stmt.executeQuery("SELECT * FROM ...") ;

int rows = stmt.executeUpdate("INSERT INTO ...") ;

boolean flag = stmt.execute(String sql) ;

六、处理结果 两种情况：
1、执行更新返回的是本次操作影响到的记录数。

2、执行查询返回的结果是一个ResultSet对象。

ResultSet包含符合SQL语句中条件的所有行，并且它通过一套get方法提供了对这些行中数据的访问。

使用结果集（ResultSet）对象的访问方法获取数据：

while(rs.next()){

String name = rs.getString("name") ;

String pass = rs.getString(1); // 此方法比较高效（列是从左到右编号的，并且从列1开始）
}

七、关闭JDBC对象
操作完成以后要把所有使用的JDBC对象全都关闭，以释放JDBC资源，关闭顺序和声明顺序相反：

1、关闭记录集

2、关闭声明

3、关闭连接对象

if(rs != null){ // 关闭记录集
try{
rs.close() ;
}catch(SQLException e){
e.printStackTrace() ;
}
}

if(stmt != null){ // 关闭声明
try{
stmt.close() ;
}catch(SQLException e){
e.printStackTrace() ;
}
}

if(conn != null){ // 关闭连接对象
try{
conn.close() ;
}catch(SQLException e){
e.printStackTrace() ;
}
}

(9)java读写mysql数据库扩展阅读

样例

package first;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

import java.util.concurrent.Executors;

import java.util.concurrent.ScheledExecutorService;

import java.util.concurrent.TimeUnit;

public class lianjie {

public static void main(String[] args) {

Runnable runnable = new Runnable() {

public void run() {

//声明Connection对象

Connection con;

//驱动程序名

String driver1 = "com.microsoft.sqlserver.jdbc.SQLServerDriver";

//URL指向要访问的数据库名

String url1 = "jdbc:sqlserver://IP地址和端口号;DateBaseName=数据库名";

//MySQL配置时的用户名

String user1 = "user";

//MySQL配置时的密码

String password1 = "user";

//声明Connection对象

Connection con1;

//驱动程序名

String driver2 = "com.microsoft.sqlserver.jdbc.SQLServerDriver";

//URL指向要访问的数据库名

String url2 = "jdbc:sqlserver://IP地址和端口号;DateBaseName=数据库名";

//MySQL配置时的用户名

String user2 = "user";

//MySQL配置时的密码

String password2 = "user";

//遍历查询结果集

try {

//加载驱动程序

Class.forName(driver1);

//1.getConnection()方法，连接MySQL数据库！！

con = DriverManager.getConnection(url1,user1,password1);

if(!con.isClosed())

System.out.println("成功连接到数据库!");

try {

//加载驱动程序

Class.forName(driver2);

//1.getConnection()方法，连接MySQL数据库！！

con1 = DriverManager.getConnection(url2,user2,password2);

if(!con1.isClosed())

System.out.println("成功连接到数据库!");

//2.创建statement类对象，用来执行SQL语句！！

Statement statement = con.createStatement();

//要执行的SQL语句

String sql = "use 数据库名 select * from 表名";

//3.ResultSet类，用来存放获取的结果集！！

ResultSet rs = statement.executeQuery(sql);

//要执行的SQL语句

String sql1 = "use tiantiana insert into Table_1(tiantian,qiqi,yuyu)VALUES(?,?,?)";

//3.ResultSet类，用来存放获取的结果集！！

PreparedStatement pst = con1.prepareStatement(sql1);

System.out.println ("tiantian"+"/t"+"qiqi"+"/t"+"yuyu");

while(rs.next()){

System.out.print(rs.getString(1));

System.out.print(rs.getString(2));

System.out.print(rs.getString(3));

pst.setString(1,rs.getString(1));

pst.setString(2,rs.getString(2));

pst.setString(3,rs.getString(3));

pst.executeUpdate();

}

pst.close();

rs.close();

//2.创建statement类对象，用来执行SQL语句！！

Statement statement1 = con.createStatement();

//要执行的SQL语句

String sql2 = "use 数据库名 select * from 表名";

//3.ResultSet类，用来存放获取的结果集！！

ResultSet rs1 = statement1.executeQuery(sql2);

//要执行的SQL语句

String sql3 = "use tiantiana insert into Table_2(tiantian1,qiqi1,yuyu1)VALUES(?,?,?)";

//3.ResultSet类，用来存放获取的结果集！！

PreparedStatement pst1 = con1.prepareStatement(sql3);

System.out.println ("tiantian1"+"/t"+"qiqi1"+"/t"+"yuyu1");

while(rs1.next()){

System.out.print(rs1.getString(1));

System.out.print(rs1.getString(2));

System.out.print(rs1.getString(3));

pst1.setString(1,rs1.getString(1));

pst1.setString(2,rs1.getString(2));

pst1.setString(3,rs1.getString(3));

pst1.executeUpdate();

}

//关闭链接

rs1.close();

pst.close();

con1.close();

con.close();

} catch(ClassNotFoundException e) {

//数据库驱动类异常处理

System.out.println("对不起,找不到驱动程序!");

e.printStackTrace();

} catch(SQLException e) {

//数据库连接失败异常处理

e.printStackTrace();

}catch (Exception e) {

// TODO: handle exception

e.printStackTrace();

}finally{

System.out.println("数据库数据成功获取！！");

}

} catch(ClassNotFoundException e) {

//数据库驱动类异常处理

System.out.println("对不起,找不到驱动程序!");

e.printStackTrace();

} catch(SQLException e) {

//数据库连接失败异常处理

e.printStackTrace();

}catch (Exception e) {

// TODO: handle exception

e.printStackTrace();

}finally{

System.out.println("数据库数据成功获取！！");

}

}

};

ScheledExecutorService service = Executors

.();

// 第二个参数为首次执行的延时时间，第三个参数为定时执行的间隔时间

service.scheleAtFixedRate(runnable, 10, 60*2, TimeUnit.SECONDS);

}

}

J. 如何在Java程序中访问mysql数据库中的数据并进行简单的操作

参考代码：
package 数据库编程;
import java.sql.*;
public class 数据库连接 {
public static void main(String[] args) throws SQLException{
//1.加载驱动程序
try {
Class.forName("com.mysql.jdbc.Driver");
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
//2.创建与DB数据库的连接
//连接字符串
String url="jdbc:mysql://192.168.1.101:3306/java数据库?user=root&password=humin";
Connection con=DriverManager.getConnection(url);
//进行读写
if(!con.isClosed()){
System.out.print("欢迎访问数据库！\n想做什么啊………………\n");
Statement st=con.createStatement();
ResultSet rs= st.executeQuery("select * from stu");
while(rs.next()){
System.out.print( rs.getString("stuid")+","+rs.getString("name")+","+rs.getString("sex")+","+rs.getString("age")+","+rs.getString("address")+","+rs.getString("tel")+"\n");
}
}
//关闭数据库
con.close();
}

}