JDBC连接MySQL.docx
- 文档编号:14708972
- 上传时间:2023-06-26
- 格式:DOCX
- 页数:18
- 大小:22.65KB
JDBC连接MySQL.docx
《JDBC连接MySQL.docx》由会员分享,可在线阅读,更多相关《JDBC连接MySQL.docx(18页珍藏版)》请在冰点文库上搜索。
JDBC连接MySQL
JDBC连接MySQL经典方案
最近在学习数据库开发的一些实例,这里浅谈一下用JDBC连接数据库MySQL(当然也可以连接SQLSever或Oracle了,只是我更喜欢开源软件,同时也更简单)。
首先正确安装好MySQL,建立好数据库studentinfo
mysql>createdatabasestudentinfo;
然后编写java代码,ConnectToMySQL.java
importjava.sql.*;
publicclassConnectToMySQL{
publicstaticConnectiongetConnection()throwsSQLException,
java.lang.ClassNotFoundException{
Stringurl="jdbc:
mysql:
//localhost:
3306/studentinfo";
Class.forName("com.mysql.jdbc.Driver");
StringuserName="root";
Stringpassword="";
Connectioncon=DriverManager.getConnection(url,userName,password);
returncon;
}
publicstaticvoidmain(String[]args){
try{
Connectioncon=getConnection();
Statementsql=con.createStatement();
sql.execute("droptableifexistsstudent");
sql.execute("createtablestudent(idintnotnullauto_increment,namevarchar(20)notnulldefault'name',mathintnotnulldefault60,primarykey(id));");
sql.execute("insertstudentvalues(1,'AAA','99')");
sql.execute("insertstudentvalues(2,'BBB','77')");
sql.execute("insertstudentvalues(3,'CCC','65')");
Stringquery="select*fromstudent";
ResultSetresult=sql.executeQuery(query);
System.out.println("Student表数据如下:
");
System.out.println("---------------------------------");
System.out.println("学号"+" "+"姓名"+" "+"数学成绩");
System.out.println("---------------------------------");
intnumber;
Stringname;
Stringmath;
while(result.next()){
number=result.getInt("id");
name=result.getString("name");
math=result.getString("math");
System.out.println(number+" "+name+" "+math);
}
sql.close();
con.close();
}catch(java.lang.ClassNotFoundExceptione){
System.err.println("ClassNotFoundException:
"+e.getMessage());
}catch(SQLExceptionex){
System.err.println("SQLException:
"+ex.getMessage());
}
}
}
要注意的是使用MySQL数据库,需要用到对应的JDBC驱动程序mysql-connector-java-5.0.3
importjava.sql.Connection;
importjava.sql.DriverManager;
importjava.sql.SQLException;
importjava.sql.ResultSet;
importjava.sql.Statement;
importjava.sql.*;
publicclassBaseConnection{
privateConnectioncon=null;
protectedConnectiongetCon(){
ResultSetrs=null;
Statementstmt=null;
try{
Class.forName("org.gjt.mm.mysql.Driver");
Stringurl="jdbc:
mysql:
//192.168.0.10/数据库名?
user=USR&password=PWD";
conn=DriverManager.getConnection(url);
stmt=conn.createStatement();
}catch(ClassNotFoundExceptione){
e.printStackTrace();
}catch(SQLExceptione){
e.printStackTrace();
}
returncon;
}
}
1.把 mysql-connector-java-5.0.3-bin.jar放到%JAVA_HOME%\jre\lib\ext下
2.访问类:
packagemysqldb;
importjava.sql.*;
publicclassMysqlCon{
privatestaticStringDriverName="org.gjt.mm.mysql.Driver";
privateStringdbURL="jdbc:
mysql:
//localhost/test";
privateStringdbuser="root";
privateStringdbpassword="";
privateConnectionconn;
privateStatementstmt;
privateResultSetrs;
publicMysqlCon(){
try{
Class.forName(DriverName).newInstance();
conn=DriverManager.getConnection(dbURL,dbuser,dbpassword);
stmt=conn.createStatement();
Stringsql="select*fromworker";
rs=stmt.executeQuery(sql);
while(rs.next()){
System.out.println(rs.getString
(1));
}
}catch(InstantiationExceptione){
//TODO自动生成catch块
e.printStackTrace();
}catch(IllegalAccessExceptione){
//TODO自动生成catch块
e.printStackTrace();
}catch(ClassNotFoundExceptione){
//TODO自动生成catch块
e.printStackTrace();
}catch(SQLExceptione){
//TODO自动生成catch块
e.printStackTrace();
}
}
}
packageinterphase;
importjava.sql.ResultSet;
importjava.sql.SQLException;
importjava.util.Vector;
importjavax.swing.JFrame;
importjavax.swing.JPanel;
importjavax.swing.JScrollPane;
importjavax.swing.JTable;
importjavax.swing.table.AbstractTableModel;
importmysqldb.MysqlCon;
publicclassShowRS{
privateAbstractTableModelatm;
privateJTablejtable;
privateVectorvector;
privateJScrollPanejsp;
privateStringtitle[]={"职工号","职工名","性别","出生日期","工资"};
privateMysqlConmysqlcon;
privateJFrameframe;
publicShowRS(){
vector=newVector();
atm=newAbstractTableModel(){
publicintgetColumnCount(){
returntitle.length;
}
publicintgetRowCount(){
returnvector.size();
}
publicObjectgetValueAt(introwIndex,intcolumnIndex){
if(!
vector.isEmpty())
return((Vector)vector.elementAt(rowIndex)).elementAt(columnIndex);
else
returnnull;
}
//取得单元格中的属性值
publicStringgetColumnName(intcolumnIndex){
returntitle[columnIndex];
}
//数据模型不可编辑,该方法设置为空
publicvoidsetValueAt(){}
//取得列所属对象类
publicClassgetCoumnClass(intc){
returngetValueAt(0,c).getClass();
}
//设置单元格不可编辑,为缺省实现
publicbooleanisCellEditable(introw,intcolumn){
returnfalse;
}};
jtable=newJTable(atm);
jtable.setToolTipText("显示全部查询结果");
jtable.setAutoResizeMode(JTable.AUTO_RESIZE_OFF);
jtable.setCellSelectionEnabled(false);
jtable.setShowVerticalLines(true);
jtable.setShowHorizontalLines(true);
jsp=newJScrollPane(jtable);
mysqlcon=newMysqlCon();
vector.removeAllElements();
atm.fireTableDataChanged();
try{
ResultSetrs=mysqlcon.getResultSet();
while(rs.next()){
Vectorrec_vector=newVector();
rec_vector.addElement(rs.getString
(1));
rec_vector.addElement(rs.getString
(2));
rec_vector.addElement(rs.getString(3));
rec_vector.addElement(rs.getDate(4));
rec_vector.addElement(newFloat(rs.getFloat(5)));
vector.addElement(rec_vector);
}
}catch(SQLExceptione){
//TODO自动生成catch块
e.printStackTrace();
}
atm.fireTableDataChanged();
frame=newJFrame();
frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
frame.add(jsp);
frame.setSize(400,300);
frame.setVisible(true);
}
}
教程由JAVA中文网整理校对发布(javaweb.cc)
JDBC连接MySQL
加载及注册JDBC驱动程序
Class.forName("com.mysql.jdbc.Driver");
Class.forName("com.mysql.jdbc.Driver").newInstance();
JDBCURL定义驱动程序与数据源之间的连接
标准语法:
MySQL的JDBCURL格式:
jdbc:
mysql//[hostname][:
port]/[dbname][?
param1=value1][¶m2=value2]….
示例:
jdbc:
mysql:
//localhost:
3306/sample_db?
user=root&password=your_password
常见参数:
user用户名
password密码
autoReconnect联机失败,是否重新联机(true/false)
maxReconnect尝试重新联机次数
initialTimeout尝试重新联机间隔
maxRows传回最大行数
useUnicode是否使用Unicode字体编码(true/false)
characterEncoding何种编码(GB2312/UTF-8/…)
relaxAutocommit是否自动提交(true/false)
capitalizeTypeNames数据定义的名称以大写表示
建立连接对象
Stringurl="jdbc:
mysql:
//localhost:
3306/sample_db?
user=root&password=your_password";
Connectioncon=DriverManager.getConnection(url);
建立SQL陈述式对象(StatementObject)
Statementstmt=con.createStatement();
执行SQL语句
executeQuery()
Stringquery="select*fromtest";
ResultSetrs=stmt.executeQuery(query);
结果集ResultSet
while(rs.next())
{rs.getString
(1);rs.getInt
(2);}
executeUpdate()
Stringupd="insertintotest(id,name)values(1001,xuzhaori)";
intcon=stmt.executeUpdate(upd);
execute()
示例:
try{
}
catch(SQLExceptionsqle)
{}
finally
{}
Java类型和SQL类型技术手册P421
PreparedStatement(预编语句)
PreparedStatementstmt=conn.prepareStatement("insertintotest(id,name)values(?
?
)");
stmt.setInt(1,id);
stmt.setString(2,name);
注:
一旦设定语句的参数值后,就可以多次执行改语句,直到调用clearParameters()方法将他清除为止
CallableStatement(预储程序)技术手册P430
JDBC2.0使用
ResultSet对象中的光标上下自由移动
Statementstmt=con.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_READ_ONLY);
ResultSetrs=stmt.executeQuery("select*fromtest");
publicStatementcreateStatement(intresultSetType,intresultSetConcuttency)throwsSQLException
resultSetType
TYPE_FORWARD_ONLY只能使用next()方法。
TYPE_SCROLL_SENSITIVE可以上下移动,可以取得改变后的值。
TYPE_SCROLL_INSENSITIVE可以上下移动。
resultSetConcuttency
CONCUR_READ_ONLY只读
CONCUR_UPDATABLEResultSet对象可以执行数据库的新增、修改、和移除
直接使用ResultSet对象执行更新数据
新增数据
Statementstmt=con.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_PUDATABLE);
ResultSetuprs=stmt.executeQuery("select*fromtest");
uprs.moveToInsertRow();
uprs.updateInt(1,1001);
uprs.updateString(2,"许召日");
uprs.insertRow;
更新数据
Statementstmt=con.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_PUDATABLE);
ResultSetuprs=stmt.executeQuery("select*fromtest");
uprs.last();
uprs.updateString("name","xuzhaori");
uprs.updateRow;
删除数据
Statementstmt=con.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_PUDATABLE);
ResultSetuprs=stmt.executeQuery("select*fromtest");
uprs.absolute(4);
uprs.deleteRow();
批处理
con.setAutoCommit(false);关闭自动认可模式
Statementstmt=con.createStatement();
int[]rows;
stmt.addBatch("insertintotestvalues(1001,xuzhaori)");
stmt.addBatch("insertintotestvalues(1002,xuyalin)");
rows=stmt.executeBatch();
mit();没有任何错误,执行批处理stmt.executeBatch();
JNDI-数据源(DataSource)与连接池(ConnectionPool)
Tomcat的JDBC数据源设置技术手册P439
连接池工具-ProxoolVar0.8.3技术手册P446
设置web.xml
xmlversion="1.0"encoding="ISO-8859-1"?
>
--
xmlversion="1.0"encoding="GB2312"?
>-->
xmlns: xsi="http: //www.w3.org/2001/XMLSchema-instance" xsi: schemaLocation=" version="2.4"> …. 后端统计端口添加下列
- 配套讲稿:
如PPT文件的首页显示word图标,表示该PPT已包含配套word讲稿。双击word图标可打开word文档。
- 特殊限制:
部分文档作品中含有的国旗、国徽等图片,仅作为作品整体效果示例展示,禁止商用。设计者仅对作品中独创性部分享有著作权。
- 关 键 词:
- JDBC 连接 MySQL