一个通过Java连接MySQL数据库的代码

这次的Java连接MySQL数据库操作，还是用的和那个非常小的数据库管理系统（JSP）一样的MySQL web_data 的数据库。

创新互联致力于互联网品牌建设与网络营销，包括成都网站设计、网站建设、SEO优化、网络推广、整站优化营销策划推广、电子商务、移动互联网营销等。创新互联为不同类型的客户提供良好的互联网应用定制及解决方案，创新互联核心团队十年专注互联网开发，积累了丰富的网站经验，为广大企业客户提供一站式企业网站建设服务，在网站建设行业内树立了良好口碑。

图示如下：

代码如下：

 
 
 
 
    
  
  
  
  
  1. ------------------------------------------------------------  
    2.   
  
  
  
  2.  
    3.   
  
  
  
  3. import java.sql.*;   
    4.   
  
  
  
  4. import javax.swing.*;   
    5.   
  
  
  
  5. import java.awt.*;   
    6.   
  
  
  
  6. import java.awt.event.*;   
    7.   
  
  
  
  7. import java.util.*;   
    8.   
  
  
  
  8.  
    9.   
  
  
  
  9. public class inensshow extends JFrame {   
    10.   
  
  
  
  10.  
    11.   
  
  
  
  11.  
    12.   
  
  
  
  12. private Connection connection;   
    13.   
  
  
  
  13. private Statement statement;   
    14.   
  
  
  
  14. private ResultSet resultSet;   
    15.   
  
  
  
  15. private ResultSetMetaData rsMetaData;   
    16.   
  
  
  
  16.  
    17.   
  
  
  
  17. //GUI变量定义  
    18.   
  
  
  
  18. private JTable table;   
    19.   
  
  
  
  19. private JTextArea inputQuery;   
    20.   
  
  
  
  20. private JButton submitQuery;   
    21.   
  
  
  
  21.  
    22.   
  
  
  
  22. public inensshow()   
    23.   
  
  
  
  23. {   
    24.   
  
  
  
  24. //Form的标题   
    25.   
  
  
  
  25. super( "输入SQL语句，按查询按钮查看结果。" );   
    26.   
  
  
  
  26.  
    27.   
  
  
  
  27. String url = "jdbc:mysql://localhost:3306/web";   
    28.   
  
  
  
  28. String username = "inens";   
    29.   
  
  
  
  29. String password = "inens";   
    30.   
  
  
  
  30. //加载驱动程序以连接数据库  
    31.   
  
  
  
  31. try {   
    32.   
  
  
  
  32. Class.forName( "org.gjt.mm.mysql.Driver" );   
    33.   
  
  
  
  33. connection = DriverManager.getConnection(   
    34.   
  
  
  
  34. url, username, password );   
    35.   
  
  
  
  35. }   
    36.   
  
  
  
  36. //捕获加载驱动程序异常  
    37.   
  
  
  
  37. catch ( ClassNotFoundException cnfex ) {   
    38.   
  
  
  
  38. System.err.println(   
    39.   
  
  
  
  39. "装载 JDBC/ODBC 驱动程序失败。" );   
    40.   
  
  
  
  40. cnfex.printStackTrace();   
    41.   
  
  
  
  41. System.exit( 1 ); // terminate program   
    42.   
  
  
  
  42. }   
    43.   
  
  
  
  43. //捕获连接数据库异常  
    44.   
  
  
  
  44. catch ( SQLException sqlex ) {   
    45.   
  
  
  
  45. System.err.println( "无法连接数据库" );   
    46.   
  
  
  
  46. sqlex.printStackTrace();   
    47.   
  
  
  
  47. System.exit( 1 ); // terminate program   
    48.   
  
  
  
  48. }   
    49.   
  
  
  
  49. //如果数据库连接成功，则建立GUI  
    50.   
  
  
  
  50. //SQL语句  
    51.   
  
  
  
  51. String test="SELECT * FROM data";   
    52.   
  
  
  
  52. inputQuery = new JTextArea( test, 4, 30 );   
    53.   
  
  
  
  53. submitQuery = new JButton( "查询" );   
    54.   
  
  
  
  54. //Button事件  
    55.   
  
  
  
  55. submitQuery.addActionListener(   
    56.   
  
  
  
  56. new ActionListener() {   
    57.   
  
  
  
  57. public void actionPerformed( ActionEvent e )   
    58.   
  
  
  
  58. {   
    59.   
  
  
  
  59. getTable();   
    60.   
  
  
  
  60. }   
    61.   
  
  
  
  61. }   
    62.   
  
  
  
  62. );   
    63.   
  
  
  
  63.  
    64.   
  
  
  
  64. JPanel topPanel = new JPanel();   
    65.   
  
  
  
  65. topPanel.setLayout( new BorderLayout() );   
    66.   
  
  
  
  66. //将"输入查询"编辑框布置到 "CENTER"  
    67.   
  
  
  
  67. topPanel.add( new JScrollPane( inputQuery), BorderLayout.CENTER );   
    68.   
  
  
  
  68. //将"提交查询"按钮布置到 "SOUTH"  
    69.   
  
  
  
  69. topPanel.add( submitQuery, BorderLayout.SOUTH );   
    70.   
  
  
  
  70. table = new JTable();   
    71.   
  
  
  
  71. Container c = getContentPane();   
    72.   
  
  
  
  72. c.setLayout( new BorderLayout() );   
    73.   
  
  
  
  73. //将"topPanel"编辑框布置到 "NORTH"  
    74.   
  
  
  
  74. c.add( topPanel, BorderLayout.NORTH );   
    75.   
  
  
  
  75. //将"table"编辑框布置到 "CENTER"  
    76.   
  
  
  
  76. c.add( table, BorderLayout.CENTER );   
    77.   
  
  
  
  77. getTable();   
    78.   
  
  
  
  78. setSize( 500, 300 );   
    79.   
  
  
  
  79. //显示Form  
    80.   
  
  
  
  80. show();   
    81.   
  
  
  
  81. }   
    82.   
  
  
  
  82.  
    83.   
  
  
  
  83. private void getTable()   
    84.   
  
  
  
  84. {   
    85.   
  
  
  
  85. try {   
    86.   
  
  
  
  86. //执行SQL语句  
    87.   
  
  
  
  87. String query = inputQuery.getText();   
    88.   
  
  
  
  88. statement = connection.createStatement();   
    89.   
  
  
  
  89. resultSet = statement.executeQuery( query );   
    90.   
  
  
  
  90. //在表格中显示查询结果  
    91.   
  
  
  
  91. displayResultSet( resultSet );   
    92.   
  
  
  
  92. }   
    93.   
  
  
  
  93. catch ( SQLException sqlex ) {   
    94.   
  
  
  
  94. sqlex.printStackTrace();   
    95.   
  
  
  
  95. }   
    96.   
  
  
  
  96. }   
    97.   
  
  
  
  97.  
    98.   
  
  
  
  98. private void displayResultSet( ResultSet rs )   
    99.   
  
  
  
  99. throws SQLException   
    100.   
  
  
  
  100. {   
    101.   
  
  
  
  101. //定位到达第一条记录  
    102.   
  
  
  
  102. boolean moreRecords = rs.next();   
    103.   
  
  
  
  103. //如果没有记录，则提示一条消息  
    104.   
  
  
  
  104. if ( ! moreRecords ) {   
    105.   
  
  
  
  105. JOptionPane.showMessageDialog( this,   
    106.   
  
  
  
  106. "结果集中无记录" );   
    107.   
  
  
  
  107. setTitle( "无记录显示" );   
    108.   
  
  
  
  108. return;   
    109.   
  
  
  
  109. }   
    110.   
  
  
  
  110. Vector columnHeads = new Vector();   
    111.   
  
  
  
  111. Vector rows = new Vector();   
    112.   
  
  
  
  112. try {   
    113.   
  
  
  
  113. //获取字段的名称  
    114.   
  
  
  
  114. ResultSetMetaData rsrsmd = rs.getMetaData();   
    115.   
  
  
  
  115. for ( int i = 1; i <= rsmd.getColumnCount(); ++i )   
    116.   
  
  
  
  116. columnHeads.addElement( rsmd.getColumnName( i ) );   
    117.   
  
  
  
  117. //获取记录集  
    118.   
  
  
  
  118. do {   
    119.   
  
  
  
  119. rows.addElement( getNextRow( rs, rsmd ) );   
    120.   
  
  
  
  120. } while ( rs.next() );   
    121.   
  
  
  
  121. //在表格中显示查询结果  
    122.   
  
  
  
  122. table = new JTable( rows, columnHeads );   
    123.   
  
  
  
  123. JScrollPane scroller = new JScrollPane( table );   
    124.   
  
  
  
  124. Container c = getContentPane();   
    125.   
  
  
  
  125. c.remove(1);   
    126.   
  
  
  
  126. c.add( scroller, BorderLayout.CENTER );   
    127.   
  
  
  
  127. //刷新Table  
    128.   
  
  
  
  128. c.validate();   
    129.   
  
  
  
  129. }   
    130.   
  
  
  
  130. catch ( SQLException sqlex ) {   
    131.   
  
  
  
  131. sqlex.printStackTrace();   
    132.   
  
  
  
  132. }   
    133.   
  
  
  
  133. }   
    134.   
  
  
  
  134.  
    135.   
  
  
  
  135.  
    136.   
  
  
  
  136. private Vector getNextRow( ResultSet rs,   
    137.   
  
  
  
  137. ResultSetMetaData rsmd )   
    138.   
  
  
  
  138. throws SQLException   
    139.   
  
  
  
  139. {   
    140.   
  
  
  
  140. Vector currentRow = new Vector();   
    141.   
  
  
  
  141. for ( int i = 1; i <= rsmd.getColumnCount(); ++i )   
    142.   
  
  
  
  142. currentRow.addElement( rs.getString( i ) );   
    143.   
  
  
  
  143. //返回一条记录   
    144.   
  
  
  
  144. return currentRow;   
    145.   
  
  
  
  145. }   
    146.   
  
  
  
  146.  
    147.   
  
  
  
  147. public void shutDown()   
    148.   
  
  
  
  148. {   
    149.   
  
  
  
  149. try {   
    150.   
  
  
  
  150. //断开数据库连接  
    151.   
  
  
  
  151. connection.close();   
    152.   
  
  
  
  152. }   
    153.   
  
  
  
  153. catch ( SQLException sqlex ) {   
    154.   
  
  
  
  154. System.err.println( "Unable to disconnect" );   
    155.   
  
  
  
  155. sqlex.printStackTrace();   
    156.   
  
  
  
  156. }   
    157.   
  
  
  
  157. }   
    158.   
  
  
  
  158.  
    159.   
  
  
  
  159. public static void main( String args[] )   
    160.   
  
  
  
  160. {   
    161.   
  
  
  
  161. final inensshow app =   
    162.   
  
  
  
  162. new inensshow();   
    163.   
  
  
  
  163. app.addWindowListener(   
    164.   
  
  
  
  164. new WindowAdapter() {   
    165.   
  
  
  
  165. public void windowClosing( WindowEvent e )   
    166.   
  
  
  
  166. {   
    167.   
  
  
  
  167. app.shutDown();   
    168.   
  
  
  
  168. System.exit( 0 );   
    169.   
  
  
  
  169. }   
    170.   
  
  
  
  170. }   
    171.   
  
  
  
  171. );   
    172.   
  
  
  
  172. }   
    173.   
  
  
  
  173. }   
    174.   
  
  
  
  174.  
    175.

------------------------------------------------------------

这次在WIN98中就不好使了。因为MySQL的驱动程序没有也没能加入到CLASSPATH 当中，但是JSP却可以使用（JSP的98驱动加载详见Jsp与Mysql连接查错文章），所以这次我是在XPServer中测试的。Java连接MySQL成功。

当前题目：一个通过Java连接MySQL数据库的代码
转载来源：http://www.shufengxianlan.com/qtweb/news15/295715.html

网站建设、网络推广公司-创新互联，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 创新互联

猜你还喜欢下面的内容

建站公司知识

分类信息网

成都app软件开发　　 　成都电商解决方案　　 　成都400电话　　 　网站快速收录　　 　郫县封阳台　　 　整合营销　　 　新网创想　　 　关键词排名　　 　微信小程序开发　　 　四川雅安服务器托管　　 　重庆服务器托管　　 　眉山做网站　　 　广汉锦华　　 　成都网站设计公司　　 　黔盛装饰　　 　电子商务商城网站　　 　h5页面制作　　 　成都网站设计　　 　软文推广公司　　 　德信企业管理