java对mysql数据库的操作

⑴ 如何使用java访问Mysql数据库

第1步 获取Java与MySQL的连接器
第2步 将下载的包存放在自己机器上jdk安装目录下面的jre目录下面的lib目录下面的ext目录中，在程序中导入与数据库操作相关的对象
import java.sql.Connection; //导入数据库连接对象
import java.sql.DriverManager; //导入数据库驱动管理对象
import java.sql.ResultSet; //导入数据记录集对象
import java.sql.SQLException; //导入数据SQL操作异常对象
import java.sql.Statement; //导入SQL操作接口对象
第3步：在程序中写入如下内容
String url; //连接数据库的字符串
String sql; //执行数据sql查询操作的字符串
Connection conn; //数据库连接变量
Statement st; //数据库操作对象
ResultSet rs; //数据记录集对象
url = "jdbc:mysql://localhost:3306/test?user=root&password="; //在程序中只要修改这句，就可以实现数据库连接
try {
conn = DriverManager.getConnection(url);
st = conn.createStatement();
sql = "select * from test"; //只要修改这句，就可以实现各种查询操作
rs=st.executeQuery(sql); //执行数据查询
while(rs.next())
{
System.out.println(rs.getString(1)); //获得数据表test中第1个字段的数据，该字段为字符串类型
System.out.println(rs.getString(2)); //获得数据表test中第2个字段的数据，该字段为字符串类型
}
rs.close(); //关闭数据记录集
conn.close(); //关闭数据库连接
} catch (SQLException e) {
System.out.println("Error:"+e.toString()+e.getMessage());
}

⑵ java如何操作mysql数据库

具体报什么错误啊，你的包有没有导入进去啊？

publicConnectiongetConnection(){try{Class.forName("com.mysql.jdbc.Driver");Stringurl="jdbc:mysql://localhost:3306/test";Stringuser="root";StringpassWord="";conn=DriverManager.getConnection(url,user,passWord);if(conn!=null){System.out.println("数据库连接成功");}}catch(Exceptione){e.printStackTrace();}returnconn;}

⑶ 如何在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();
}

}

⑷ 通过java代码如何实现对mysql数据库进行创建新的数据库的操作

1 import java.sql.Connection;
2 import java.sql.DriverManager;
3 import java.sql.ResultSet;
4 import java.sql.SQLException;
5 import java.sql.Statement;
6
7 public class CreateDataSource {
8
9 /**
10 * @param args
11 */
12 public static void main(String[] args) {
13 // TODO Auto-generated method stub
14 String database = "test2";
15 new CreateDataSource().getConn(database);
16 }
17
18 String mysqlDriver = "com.mysql.jdbc.Driver";
19 String url = "jdbc:mysql://localhost:3306/test1";
20 String newUrl = "jdbc:mysql://localhost:3306/";
21 String username = "root";
22 String password = "root";
23 Connection conn = null;
24 Connection newConn = null;
25
26 public Connection getConn(String database) {
27
28 try {
29 Class.forName(mysqlDriver);
30 } catch (ClassNotFoundException e) {
31 // TODO Auto-generated catch block
32 e.printStackTrace();
33 }
34 try {
35 String tableSql = "create table t_user (username varchar(50) not null primary key,"
36 + "password varchar(20) not null ); ";
37 String databaseSql = "create database " + database;
38
39 conn = DriverManager.getConnection(url, username, password);
40 Statement smt = conn.createStatement();
41 if (conn != null) {
42 System.out.println("数据库连接成功!");
43
44 smt.executeUpdate(databaseSql);
45
46 newConn = DriverManager.getConnection(newUrl + database,
47 username, password);
48 if (newConn != null) {
49 System.out.println("已经连接到新创建的数据库：" + database);
50
51 Statement newSmt = newConn.createStatement();
52 int i = newSmt.executeUpdate(tableSql);//DDL语句返回值为0;
53 if (i == 0) {
54 System.out.println(tableSql + "表已经创建成功!");
55 }
56 }
57 }
58
59 } catch (SQLException e1) {
60 // TODO Auto-generated catch block
61 e1.printStackTrace();
62 }
63 return conn;
64 }
65 }

⑸ 怎么在java中操作mysql数据库

1.安装好jre环境和和jdk，设置好环境变量，很基础，网上教程很多；

2.安装mysql数据库，不用设置数据源和环境变量，只是安装好就可以，具体过程见网上教程，有时候不好安装，可能是因为之前安装没有卸载干净等原因，多查一查怎么弄，多试一试就成功了；

3.为了方便操作数据库，为mysql安装一个可视化界面Navicat，安装过程超级简单，使用也超级简单，傻瓜操作；

4.怎么连接java和mysql呢，这个搞了好久，网上下载一个压缩包mysql-connector-java-5.0.8.zip，解压，将其中的mysql-connector-java-5.0.8-bin.jar文件复制一份粘贴在C:\Program
Files\Java\jre7\lib\ext目录下，也就是放在jre\lib\ext下就行；

5.接下来还要设置一次环境变量，第4步中的压缩包解压后，将解压后文件中mysql-connector-java-5.0.8-bin.jar添加到环境变量classpath中；

⑹ java程序中如何实现对mysql数据库中表的锁定

方法1：用mysql命令锁住表.

publicvoidtest(){

Stringsql="locktablesaa1write";
//或Stringsql="locktablesaa1read";
//如果想锁多个表locktablesaa1read,aa2write,.....
Stringsql1="select*fromaa1";

Stringsql2="unlocktables";
try{
this.pstmt=conn.prepareStatement(sql);
this.pstmt1=conn.prepareStatement(sql1);
this.pstmt2=conn.prepareStatement(sql2);
pstmt.executeQuery();
pstmt1.executeQuery();
pstmt2.executeQuery();

}catch(Exceptione){
System.out.println("异常"+e.getMessage());
}

}

对于read lock 和 write lock官方说明：
1.如果一个线程获得一个表的READ锁定，该线程（和所有其它线程）只能从该表中读取。
如果一个线程获得一个表的WRITE锁定，只有保持锁定的线程可以对表进行写入。
其它的线程被阻止，直到锁定被释放时为止。

2.当您使用LOCK TABLES时，您必须锁定您打算在查询中使用的所有的表。
虽然使用LOCKTABLES语句获得的锁定仍然有效，但是您不能访问没有被此语句锁定的任何的表。
同时，您不能在一次查询中多次使用一个已锁定的表——使用别名代替，
在此情况下，您必须分别获得对每个别名的锁定。

对与read lock 和 write lock个人说明：
1.read lock 和 write lock 是线程级(表级别).
2.在同一个会话中加了read lock锁. 只能对这个表进行读操作.对这个表以外的任何表都无法进行增、删、改、查的操作.
但是在不同会话中，只能对加了read lock的表进行读操作.但可以对read lock以外的表进行增、删、改、查的操作.
3.在同一个会话中加了write lock锁.只能对这个表进行读、写操作.对这个表以外的任何表都无法进行增、删、改、查的操作.
但是在不同会话中,无法对加了write lock的表进行读、写操作.但可以对write lock以外的表进行增、删、改、查的操作.
4.如果表中使用了别名.(SELECT * FROM aa1 AS byname_table)
在对aa1加锁时，必须把别名加上去(lock tables aa1 as byname_table read)
在同一个会话中.必须使用别名进行查询.
在不同的会话中.可以不需要使用别名进行查询.
5.在多个会话中可以对同一个表进行lock read操作.但不能在多个会话中对同一个表进行lock write操作（这些锁将等待已锁的表释放自身的线程锁）
如果多个会话对同一个表进行lock read操作.那么在这些会话中,也只能对以锁的表进行读操作.
6.如果要你锁住了一个表，需要嵌套查询.你必须使用别名，并且，要锁定别名.
例如.lock table aa1 read ,aa1 as byname_table read;
select * from aa1 where id in (select * from aa1 as xxwhere id=2);
7.解锁必须用unlock tables;

另:
在JAVA程序中,要想解锁,需要调用 unlock tables来解锁.
如果没有调用unlock tables.
关闭connection 、程序结束 、调用GC 都能解锁.

方法2：用记录锁锁表.

publicvoidtest(){

Stringsql="select*fromaa1forupdate";
//select*fromaa1lockinsharemode;

try{
conn.setAutoCommit(false);
this.pstmt=conn.prepareStatement(sql);
pstmt.executeQuery();

}catch(Exceptione){
System.out.println("异常"+e.getMessage());
}

}

1.for update 与 lock in share mode 属于行级锁和页级锁

2.for update 排它锁,lock in share mode 共享锁

3.对于记录锁.必须开启事务.

4.行级锁定事实上是索引记录的锁定.只要是用索引扫描的行（或没索引全表扫描的行）,都将被锁住.

5.在不同的隔离级别下还会使用next-key locking算法.即所扫描的行之间的“间隙”也会也锁住(在Repeatable read和Serializable隔离级别下有间隙锁).

6.在mysql中共享锁的含义是:在被共享锁锁住的行,即使内容被修改且并没有提交.在另一个会话中依然看到最新修改的信息.

在同一会话中加上了共享锁.可以对这个表以及这个表以外的所有表进行增、删、改、查的操作.

在不同的会话中.可以查到共享锁锁住行的最新消息.但是在Read Uncommitted隔离级别下不能对锁住的表进行删，

改操作.（需要等待锁释放才能操作...）
在Read Committed隔离级别下不能对锁住的表进行删，改操作.（需要等待锁释放才能操作...）
在Repeatable read隔离级别下不能对锁住行进行增、删、改操作.（需要等待锁释放才能操作...）
在Serializable隔离级别下不能对锁住行进行增、删、改操作.（需要等待锁释放才能操作...）

7.在mysql中排他锁的含义是:在被排它锁锁住的行,内容修改并没提交，在另一个会话中不会看到最新修改的信息。

在不同的会话中.可以查到共享锁锁住行的最新消息.但是Read Uncommitted隔离级别下不能对锁住的表进行删，

改操作.（需要等待锁释放才能操作...）
在Read Committed隔离级别下不能对锁住的表进行删，改操作.（需要等待锁释放才能操作...）
在Repeatable read隔离级别下不能对锁住行进行增、删、改操作.（需要等待锁释放才能操作...）
在Serializable隔离级别下不能对锁住行进行增、删、改操作. （需要等待锁释放才能操作...）

8.在同一个会话中的可以叠加多个共享锁和排他锁.在多个会话中,需要等待锁的释放.

9.SQL中的update 与 for update是一样的原理.

10.等待超时的参数设置:innodb_lock_wait_timeout=50 (单位秒).

11.任何可以触发事务提交的命令,都可以关闭共享锁和排它锁.

⑺ java怎么操作mysql数据库

通过jdbc；
class.forName("com.mysql.jdbc.Driver");//加载驱动类
Drivermanager.getConnection(url,userName,password);//获取链接

⑻ java 操作数据库 MySQL

这种你要分两步进行，第一步，把符合条件的ID（主键）都查出来
然后，从结果中取出第一个id，传入delete from 表名 where 条件=第一个id
用jdbc就可以删除了。

⑼ 对于java操作mysql数据库删除一行的问题

小兄弟，你的问题具体是什么？

那我就自己猜了，你的这个数据库操作，少了 DBTransaction 数据库操作对象；、

如果对回答满意，请点【采纳答案】，如果还有问题，请点【追问】

希望我的回答对您有所帮助，希望能采纳。

⑽ JAVA 如何实现与MYSQL数据库建立连接

你根据这个改一下就可以了。
别忘了在你的项目中加入mysql驱动包。

希望对你有帮助

Connection conn=null;
Statement stm=null;
ResultSet rs=null;

try {
Class.forName("org.gjt.mm.mysql.Driver").newInstance();
String url ="jdbc:mysql://localhost/myDB?user=root&password=aaaaaa&useUnicode=true&characterEncoding=8859_1";
//user是用户名，password是密码 myDB为数据库名
conn= DriverManager.getConnection(url);
stm=conn.createStatement();
这里写你的SQL
} catch (Exception e) {
// TODO Auto-generated catch block

} finally{
try {
stm.close();
conn.close();
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}