Java连接mysql数据库源代码

更新时间：2023-08-21 08:15:01 阅读量：高等教育文档下载

说明：文章内容仅供预览，部分内容可能不全。下载后的文档，内容与下面显示的完全一致。下载之前请确认下面内容是否您想要的，是否完整无缺。

本程序使用Java+Mysql进行编写,其中主要是对数据库进行数据的更新及维护工作,主要界面为DOS界面,如有兴趣的同仁,可修改成GUI界面的,方便进行操作及管理。

Java连接mysql数据库源代码

/**

*@author mervyn

*@Development_time 2011.3.12

*welcome to /mervyn_hb

package src;

import java.io.IOException;

import java.io.UnsupportedEncodingException;

import java.sql.*;

import java.util.*;

public class MysqlConnectSystem {

/**

* @param args

* @throws IOException

public static void main(String[] args) throws SQLException, IOException {

String Usename,KeyID,UrlString;

//String DriverConnect;

char MenuExitValue;

String driver="com.mysql.jdbc.Driver";

Scanner EntryValue=new Scanner(System.in);

System.out.println("欢迎使用MysqlConnectSystem信息管理系统！"); MysqlConnectSystem mysqlconnect=new MysqlConnectSystem(); MysqlConnectSystem mysqlinsert=new MysqlConnectSystem(); MysqlConnectSystem mysqlupdate=new MysqlConnectSystem(); MysqlConnectSystem mysqldelete=new MysqlConnectSystem();

System.out.println("请输入要登录的用户名：");

Usename=EntryValue.next();

System.out.println("请输入要登录的数据库的密码："); KeyID=EntryValue.next();

System.out.println("请输入需要登录的数据库：");

UrlString="jdbc:mysql://127.0.0.1:3306/"+EntryValue.next(); do{

try {

Class.forName(driver);

Connection conn=DriverManager.getConnection(UrlString, Usename,

KeyID);

if(!conn.isClosed())

{

int MenuSelectValue;

System.out.println("Succeeded connectint to the database company!!");

System.out.println("请选择需要的操作：1、查询数据 2、插入数据 3、更新数据 4、删除数据 ");

MenuSelectValue=EntryValue.nextInt();

switch (MenuSelectValue){

case 1:

mysqlconnect.Mysql_ConnectExecute_Select(Usename,KeyID,UrlString);

break;

case 2:

mysqlinsert.Mysql_ConnectExecute_Insert(Usename,KeyID,UrlString);

break;

case 3:

mysqlupdate.Mysql_ConnextExecute_Update(Usename,KeyID,UrlString);

break;

case 4:

mysqldelete.Mysql_ConnectExecute_Delete(Usename,KeyID,UrlString);

break;

default:

}

conn.close();

//Statement statement=conn.createStatement();

}

}catch (ClassNotFoundException e) {

// TODO 自动生成 catch 块

//e.printStackTrace();

System.out.println("找不到JDBC驱动模块！");

}catch (InputMismatchException e){

System.out.println("输入非法的字符！");

}

System.out.println("是否退出系统？返回主菜单（m）退出（e)"); MenuExitValue=(char)System.in.read();

}while(MenuExitValue!='e');

System.out.println("程序已结束！");

}

the Program is to Select the database!!!

public void Mysql_ConnectExecute_Select(String UseNameValue,String KeyIDValue,String UrlinforValue)

{

String SelectDriver="com.mysql.jdbc.Driver";

String Select_By_Usename,Select_By_KeyID,Select_By_Urlinfor; int SelectStyleValue;

Scanner EntryValue=new Scanner(System.in);

try {

Class.forName(SelectDriver);

Connection conn=DriverManager.getConnection(UrlinforValue, UseNameValue, KeyIDValue);

if(!conn.isClosed())

{

Statement statement=conn.createStatement();

System.out.println("请选择查询的方式：1、按姓名查询 2、按密码查询 3、按网址查询 4、全部显示");

SelectStyleValue=EntryValue.nextInt();

switch (SelectStyleValue){

case 1:

System.out.println("请输入要查找的用户名：");

Select_By_Usename=EntryValue.next();

String SelectExecuteState="select * from urlinformation where usename='"+Select_By_Usename+"'";

ResultSet rs=statement.executeQuery(SelectExecuteState);

System.out.println("---------------------------------------------------------------------");

System.out.println("the result is:");

System.out.println("---------------------------------------------------------------------");

System.out.println("Name"+" "+"keyid"+" "+"urlinfor");

System.out.println("----------------------------------------

-----------------------------");

String ReUseNameValue=null;

while(rs.next()) {

ReUseNameValue = rs.getString("usename");

ReUseNameValue=new

String(ReUseNameValue.getBytes("ISO-8859-1"),"GB2312");

System.out.println(ReUseNameValue+" "+rs.getString("Keyid")+" "+rs.getString("urlinfor"));

}

rs.close();

break;

case 2:

System.out.println("请输入要查找的密码：");

Select_By_KeyID=EntryValue.next();

String SelectExecuteStateValue="select * from urlinformation where keyid='"+Select_By_KeyID+"'";

ResultSet rsk=statement.executeQuery(SelectExecuteStateValue); System.out.println("---------------------------------------------------------------------");

System.out.println("the result is:");

System.out.println("---------------------------------------------------------------------");

System.out.println("Name"+" "+"keyid"+" "+"urlinfor");

System.out.println("---------------------------------------------------------------------");

String ReKeyIDValue=null;

while(rsk.next()){

ReKeyIDValue=rsk.getString("keyid");

ReKeyIDValue=new

String(ReKeyIDValue.getBytes("ISO-8859-1"),"GB2312");

System.out.println(rsk.getString("usename")+" "+ReKeyIDValue+" "+ rsk.getString("urlinfor"));

}

rsk.close();

break;

case 3:

System.out.println("请输入要查找的网址：");

Select_By_Urlinfor=EntryValue.next();

String SelectExecuteStateValueUrl="select * from urlinformation where urlinfor='"+Select_By_Urlinfor+"'";

ResultSet

rsu=statement.executeQuery(SelectExecuteStateValueUrl);

System.out.println("---------------------------------------------------------------------");

System.out.println("the result is:");

System.out.println("---------------------------------------------------------------------");

System.out.println("Name"+" "+"keyid"+" "+"urlinfor");

System.out.println("---------------------------------------------------------------------");

String ReUrlinforValue=null;

while(rsu.next()){

ReUrlinforValue=rsu.getString("urlinfor");

try {

ReUrlinforValue=new

String(ReUrlinforValue.getBytes("ISO-8859-1"),"GB2312");

} catch (UnsupportedEncodingException e) {

// TODO 自动生成 catch 块

e.printStackTrace();

}

System.out.println(rsu.getString("usename")+" "+rsu.getString("keyid")+" "+ReUrlinforValue);

}

rsu.close();

break;

case 4:

String SelectAllRecord="select * from urlinformation"; ResultSet rsa=statement.executeQuery(SelectAllRecord);

System.out.println("---------------------------------------------------------------------");

System.out.println("the result is:");

System.out.println("---------------------------------------------------------------------");

System.out.println("Name"+" "+"keyid"+" "+"urlinfor");

System.out.println("---------------------------------------------------------------------");

String ReAllRecordValue=null;

while(rsa.next())

{

ReAllRecordValue=rsa.getString("usename");

ReAllRecordValue=new

String(ReAllRecordValue.getBytes("ISO-8859-1"),"GB2312");

System.out.println(rsa.getString("usename")+" "+rsa.getString("keyid")+" "+rsa.getString("urlinfor")); }

break;

default:

System.out.println("你输入非法的字符！");

}

conn.close();

} catch (UnsupportedEncodingException e) {

// TODO 自动生成 catch 块

e.printStackTrace();

}catch (ClassNotFoundException e) {

e.printStackTrace();

} catch (SQLException e) {

// TODO 自动生成 catch 块

e.printStackTrace();

}

the Program is to Select the database!!!

public void Mysql_ConnectExecute_Insert(String UseNameValue,String KeyIDValue,String UrlinforValue)

{

String InsertDriver="com.mysql.jdbc.Driver";

String InsertUseNameValue,InsertKeyIDValue,InsertUrlinforValue; String InsertDatabaseExecute;

Scanner EntryValue=new Scanner(System.in);

try {

Class.forName(InsertDriver);

Connection conn=DriverManager.getConnection(UrlinforValue, UseNameValue, KeyIDValue);

if(!conn.isClosed())

{

Statement statement=conn.createStatement();

System.out.println("请输入要插入数据库的用户名：");

InsertUseNameValue=EntryValue.next();

System.out.println("请输入密码：");

InsertKeyIDValue=EntryValue.next();

System.out.println("请输入登录的网址：");

InsertUrlinforValue=EntryValue.next();

InsertDatabaseExecute="insert into urlinformation value('"+InsertUseNameValue+"','"+InsertKeyIDValue+"','"+InsertUrlinforValue+"')";

System.out.println(InsertDatabaseExecute);

statement.executeUpdate(InsertDatabaseExecute);

System.out.println("已成功将数据插入数据库中!");

conn.close();

}

} catch (ClassNotFoundException e) {

// TODO 自动生成 catch 块

e.printStackTrace();

} catch (SQLException e) {

// TODO 自动生成 catch 块

e.printStackTrace();

//System.out.println("SQL语句异常！！！");

}

the Program is to update the database!!!

public void Mysql_ConnextExecute_Update(String UseNameValue,String KeyIDValue,String UrlinforValue)

{

String UpdateDriver="com.mysql.jdbc.Driver";

String UpdateUsenameValue,UpdateKeyIDValue,UpdateUrlinforValue; String UpdateOrderString;

Scanner EntryValue=new Scanner(System.in);

try {

Class.forName(UpdateDriver);

Connection conn=DriverManager.getConnection(UrlinforValue, UseNameValue, KeyIDValue);

if(!conn.isClosed())

{

int UpdateRecordValue;

Statement statement=conn.createStatement();

System.out.println("请选择操作类型：1、按姓名修改 2、按密码修改 3、

按网址修改（暂时提供修改密码功能）");

UpdateRecordValue=EntryValue.nextInt();

switch(UpdateRecordValue){

case 1:

String SetKeyIDValue;

System.out.println("请输入要修改密码的用户名：");

UpdateUsenameValue=EntryValue.next();

System.out.println("请输入新的密码：");

SetKeyIDValue=EntryValue.next();

UpdateOrderString="update urlinformation set keyid='"+SetKeyIDValue +"' where usename='"+UpdateUsenameValue+"'"; statement.executeUpdate(UpdateOrderString);

System.out.println("数据更新完成！！");

break;

case 2:

break;

case 3:

break;

default:

System.out.println("输入非法字符！");

}

} catch (ClassNotFoundException e) {

// TODO 自动生成 catch 块

e.printStackTrace();