java - JDBC - 双值未显示在 MySQL 数据库中-6ren

java - JDBC - 双值未显示在 MySQL 数据库中

转载作者：行者123 更新时间：2023-11-29 12:31:07

我有一个程序，它从网页上抓取价格，然后找到该价格与上次抓取的价格的差异，然后将该值发送到我的 MySQL 数据库。

查看代码之前需要注意的事项:

实际价格( double )确实被发送并正确输入到我的数据库中，尽管我的priceChange变量没有。我尝试将其更改为 BigDecimal，但没有发生任何变化。

PriceGrabber.java(现在很草率，我知道。我最终会精简代码。一旦我的核心功能开始工作。)

    import java.math.BigDecimal;
import java.text.SimpleDateFormat;
import java.util.TimerTask;
import java.util.Date;
import org.jsoup.*;
import org.jsoup.nodes.Document;
import org.jsoup.nodes.Element;
import java.util.*;
import java.lang.*;
import java.net.URL;
import java.io.*;



public class PriceGrabber extends TimerTask{


    @Override
    public void run() {


        try {

            if(Coinbase.getLastPrice() ==  Variables.getCoinbase()){
                System.out.println();
            }else {
                System.out.println("Price Change Detected in Coinbase!");
                System.out.println("Price Change: " + (Variables.getCoinbase() - Coinbase.getLastPrice()));
                Coinbase.setLastPrice(Variables.getCoinbase());
                Variables.addPrice(Variables.getCoinbase(), "Coinbase", (Variables.getCoinbase() - Coinbase.getLastPrice()));

            }
            if(BTCE.getLastPrice() ==  Variables.getBTCE()){
                System.out.println();
            }else {
                System.out.println("Price Change Detected in BTC-E!");
                System.out.println("Price Change: " + (Variables.getBTCE() - BTCE.getLastPrice()));
                BTCE.setLastPrice(Variables.getBTCE());
                Variables.addPrice(Variables.getBTCE(), "BTC-e", (Variables.getBTCE() - BTCE.getLastPrice()));
            }

            if(BitStamp.getLastPrice() ==  Variables.getBitStamp()){
                System.out.println();
            }else {
                System.out.println("Price Change Detected in BitStamp Market!");
                System.out.println("Price Change: " + (Variables.getBitStamp() - BitStamp.getLastPrice()));
                BitStamp.setLastPrice(Variables.getBitStamp());

                Variables.addPrice(Variables.getBitStamp(), "Bitstamp", (Variables.getBitStamp() - BitStamp.getLastPrice()));
            }


            if(Bitfinext.getLastPrice() ==  Variables.getBitfinext()){
                System.out.println();
            }else {
                System.out.println("Price Change Detected in Bitfinext!");
                System.out.println("Price Change: " + (Variables.getBitfinext() - Bitfinext.getLastPrice()));
                Bitfinext.setLastPrice(Variables.getBitfinext());
                Variables.addPrice(Variables.getBitfinext(), "Bitfinext", (Variables.getBitfinext() - Bitfinext.getLastPrice()));
            }



            //Variables.printPrices();


        } catch (IOException e) {

        }

    }


}

变量.java

       import java.io.*;
import java.math.BigDecimal;
import java.sql.*;
import java.util.TimerTask;
import java.util.Date;
import org.jsoup.*;
import org.jsoup.nodes.Document;
import org.jsoup.nodes.Element;
import java.util.*;
import java.lang.*;
import java.net.URL;
import java.io.*;
import java.net.MalformedURLException;
import java.text.SimpleDateFormat;
import java.util.Calendar;
import java.util.Enumeration;


    public class Variables {

        public static final String DB_URL = "jdbc:mysql://URL TO DB";

        //  Database credentials
        public static final String USER = "username";
        public static final String PASS = "password";

    //Web Elements
    public static URL url = null;
    public static Document page = null;
    public static Element priceElement = null;
    public static Document doc = null;
    public static String price;
    public static String priceString;
    public static String timeStamp;









    //Different Market URL's
    public static String coinbaseURL = "https://bitcoinwisdom.com/markets/coinbase/btcusd";
    public static String btceURL = "https://bitcoinwisdom.com/markets/btce/btcusd";
    public static String bitstampURL = "https://bitcoinwisdom.com/markets/bitstamp/btcusd";
    public static String bitfinextURL = "https://bitcoinwisdom.com/markets/bitfinex/btcusd";



    //Sets the URL
    public static void setURL(String siteURL) throws MalformedURLException, IOException{

        url = new URL(siteURL);

    }


    public static Double getCoinbase() throws IOException{

        try{
            setURL(coinbaseURL);

            page = Jsoup.parse(url, 5000);
            if(page.select("div.green").first() == null){
                priceElement = page.select("div.red").first();
            }else{
                priceElement = page.select("div.green").first();
            }

            priceString = priceElement.toString();
            doc = Jsoup.parse(priceString);
            price = doc.body().text();



        }catch(IOException e) {
            System.out.println("something went wrong");
            System.out.println(e.getMessage());
        }
        return Double.parseDouble(price);
    }

    public static Double getBTCE() throws IOException{

        try{
            setURL(btceURL);

            page = Jsoup.parse(url, 5000);
            if(page.select("div.green").first() == null){
                priceElement = page.select("div.red").first();
            }else{
                priceElement = page.select("div.green").first();
            }

            priceString = priceElement.toString();
            doc = Jsoup.parse(priceString);
            price = doc.body().text();



        }catch(IOException e){
            System.out.println("oops! Something went wrong");
            System.out.println(e.getMessage());
        }
        return Double.parseDouble(price);
    }

    public static Double getBitStamp() throws IOException {

        try {
            setURL(bitstampURL);

            page = Jsoup.parse(url, 5000);
            if (page.select("div.green").first() == null) {
                priceElement = page.select("div.red").first();
            } else {
                priceElement = page.select("div.green").first();
            }

            priceString = priceElement.toString();
            doc = Jsoup.parse(priceString);
            price = doc.body().text();


        } catch (IOException e) {
            System.out.println("oops! Something went wrong");
            System.out.println(e.getMessage());
        }
        return Double.parseDouble(price);
    }

    public static Double getBitfinext() throws IOException {

            try {
            setURL(bitfinextURL);

            page = Jsoup.parse(url, 5000);
            if (page.select("div.green").first() == null) {
                priceElement = page.select("div.red").first();
            } else {
                priceElement = page.select("div.green").first();
            }

            priceString = priceElement.toString();
            doc = Jsoup.parse(priceString);
            price = doc.body().text();


        } catch (IOException e) {
            System.out.println("oops! Something went wrong");
            System.out.println(e.getMessage());
        }
        return Double.parseDouble(price);
    }








        //***********************************************************************************\\
        //TODO:******************************************************************************\\
        //TODO:   SEARCH FOR QUEUE SYSTEM TO AVOID HAVING TO RECONNECT FOR EACH ADDITION     \\
        //TODO:******************************************************************************\\
        //***********************************************************************************\\
    public static void addPrice(Double price, String market, Double priceChange){

        java.sql.Connection conn = null;
        Statement stmt = null;
        try{
            //STEP 2: Register JDBC driver
            Class.forName("com.mysql.jdbc.Driver");

            //STEP 3: Open a connection
            conn = DriverManager.getConnection(DB_URL, USER, PASS);

            java.sql.Timestamp  sqlDate = new java.sql.Timestamp(new java.util.Date().getTime());


            String query = " insert into prices (market, price, pricechange, time_of_change)"
                    + " values (?, ?, ?, ?)";


            PreparedStatement preparedStmt = conn.prepareStatement(query);
            preparedStmt.setString (1, market);
            preparedStmt.setDouble (2, price);
            preparedStmt.setDouble(3, priceChange);
            preparedStmt.setTimestamp(4, sqlDate);


            // execute the preparedstatement
            preparedStmt.execute();

            conn.close();


        }catch(SQLException se){
            //Handle errors for JDBC
            se.printStackTrace();
        }catch(Exception e){
            //Handle errors for Class.forName
            e.printStackTrace();
        }finally{
            //finally block used to close resources
            try{
                if(stmt!=null)
                    stmt.close();
            }catch(SQLException se2){
            }// nothing we can do
            try{
                if(conn!=null)
                    conn.close();
            }catch(SQLException se){
                se.printStackTrace();
            }//end finally try
        }//end try
    }//end main




}

我将向您展示 Coinbase.java 的源代码，它与其他类(BTCE.java、Bitfinex.java 等)完全相同，只是为了节省空间

Coinbase.java(与其他市场类别相同)

    /**
 * Created by Sullivan4653 on 12/8/2014.
 */
public class Coinbase {

    public static double lastPrice = 0.0;

    public static void setLastPrice(double price){
        lastPrice = price;

    }

    public static double getLastPrice(){
        return lastPrice;
    }
}

**最后是我的 MySQL 信息:**

除了priceChange 之外，我的MySQL 数据库/表和列都可以工作。值类型设置为 Double。默认值=空。这与我的价格栏相同，它似乎有效，因为我正在获取价格值。 (又名不是像我的 PriceChange 列那样每次都是 0)

我的问题是，为什么这个 double 现在显示在我的 MySQL 数据库中？我对帖子的长度表示歉意，但我想确保我不会遗漏任何可能有助于别人理解问题的细节。我已经为此苦苦挣扎了几天，但找不到错误!

谢谢!

最佳答案

如果您已经想制作这样的东西，请停止使用静态类，深入研究 Java :)

此外，如果您想向其他人提供代码，请使用一些好的命名约定，而不是让所有内容看起来都像默认变量(IE coinbaseURL，根据您的修饰符，它应该类似于 COINBASE_URL)。

在您的代码中，您使用新值声明旧值，因此您将覆盖它(您不能再使用它，因为它已更改为新值)。这就是我的意思:

Coinbase.setLastPrice(Variables.getCoinbase());
Variables.addPrice(Variables.getCoinbase(), "Coinbase", (Variables.getCoinbase() - Coinbase.getLastPrice()));

我已经简化并改进了您的代码，这应该可行。

import java.io.IOException;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

/**
 * @author JKetelaar
 */

public class PriceGrabber implements Runnable {

    private Coinbase coinbase;
    private Variables variables;

    public PriceGrabber(){
        this.coinbase = new Coinbase(0);
        this.variables = new Variables();

        this.variables.connect();
    }

    public static void main(String[] args){
        ScheduledExecutorService scheduleTaskExecutor = Executors.newScheduledThreadPool(5);

        scheduleTaskExecutor.scheduleAtFixedRate(new PriceGrabber(), 0, 10, TimeUnit.SECONDS);
    }

    @Override
    public void run() {
        try {
            if (coinbase.getPrice() == variables.getCoinbase()) {
                System.out.println("No changes found for Coinbase...");
            } else {
                System.out.println("Price Change detected in Coinbase!");

                Double cbase = variables.getCoinbase();
                Double cprice = coinbase.getPrice();

                System.out.println("Old price: " + cprice + "\nNew price: " + cbase + "\nPrice Change: " + (cbase - cprice));
                coinbase.setPrice(cbase);
                variables.addPrice(cbase, "Coinbase", (cprice - cprice));

            }
        } catch (IOException ignored) {

        }

    }


}

public class Coinbase {

    private double price = 0.0;

    public Coinbase(double price) {
        this.price = price;
    }

    public void setPrice(double price) {
        this.price = price;
    }

    public double getPrice() {
        return price;
    }
}

import org.jsoup.Jsoup;
import org.jsoup.nodes.Document;
import org.jsoup.nodes.Element;

import java.io.IOException;
import java.net.URL;
import java.sql.*;

public class Variables {

    public static final String DB_URL = "jdbc:mysql://160.153.49.168:3306/btcprogram";

    //  Database credentials
    public static final String USER = "sully";
    public static final String PASS = "asweq123e";

    //Web Elements
    public static URL url = null;
    public static Document page = null;
    public static Element priceElement = null;
    public static Document doc = null;
    public static String price;
    public static String priceString;


    public static String coinbaseURL = "https://bitcoinwisdom.com/markets/coinbase/btcusd";
    private Connection connection;


    //Sets the URL
    public void setURL(String siteURL) throws IOException {
        url = new URL(siteURL);
    }


    public Double getCoinbase() throws IOException {

        try {
            setURL(coinbaseURL);

            page = Jsoup.parse(url, 5000);
            if (page.select("div.green").first() == null) {
                priceElement = page.select("div.red").first();
            } else {
                priceElement = page.select("div.green").first();
            }

            priceString = priceElement.toString();
            doc = Jsoup.parse(priceString);
            price = doc.body().text();


        } catch (IOException e) {
            System.out.println("something went wrong");
            System.out.println(e.getMessage());
        }
        return Double.parseDouble(price);
    }

    public void addPrice(Double price, String market, Double priceChange) {
        /**
         * In your table set the time of change to a default value, so the table will do the time itself.
         * Makes it easier for you and doesn't get complicated if you want to get others to insert prices.
         */
        this.query("INSERT INTO prices (market, price, pricechange) VALUES (?, ?, ?)", new Object[]{
                price, market, priceChange
        });
    }

    public ResultSet query(String q, Object[] args) {
        if (connection == null) {
            System.out.println("No connection to the database.");
            return null;
        }
        try {
            PreparedStatement preparedStatement = connection.prepareStatement(q);
            for (int i = 1; i <= args.length; i++) {
                if (args[i] instanceof Double){
                    preparedStatement.setDouble(i, Double.parseDouble(String.valueOf(args[i])));
                }else{
                    preparedStatement.setString(i, String.valueOf(args[i - 1]));
                }
            }
            if (q.toLowerCase().startsWith("select")) {
                return preparedStatement.executeQuery();
            } else {
                preparedStatement.executeUpdate();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return null;
    }

    public void connect() {
        try {
            Class.forName("com.mysql.jdbc.Driver");
            connection = DriverManager
                    .getConnection("jdbc:mysql://160.153.49.168:3306/btcprogram?"
                            + "user=sully&password=asweq123e");
            if (!connection.isClosed()) {
                System.out.println("Successfully connected to the database...\nReady for SQL queries!");
            }
        } catch (ClassNotFoundException | SQLException e) {
            e.printStackTrace();
        }
    }

}

关于java - JDBC - 双值未显示在 MySQL 数据库中，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/27491964/

文章推荐： sql - 选择类型为 'x'的所有记录最高为 'version'

文章推荐： sql - 具有两个参数的 PostgreSQL 中的间隔(天)

java - 如何解析名称=值^^名称=值^^名称=值
我的问题:非常具体。我正在尝试想出解析以下文本的最简单方法: ^^domain=domain_value^^version=version_value^^account_type=account_ty
Python:尝试创建与(或(值，值，值))的等价物
好吧，这就是我的困境: 我正在为 Reddit 子版 block 开发常见问题解答机器人。我在 bool 逻辑方面遇到了麻烦，需要一双更有经验的眼睛(这是我在 Python 中的第一次冒险)。现在，该
excel - 如何使循环同时运行所有 X 和 Y 值，现在它运行所有 Y 值，然后运行所有 X 值
它首先遍历所有 y 值，然后遍历所有 x 值。我需要 X 和 y 同时改变。 For x = 3 To lr + 1 For y = 2 To lr anyl.Cells(x, 1)
excel - SUMIF(条件，值)、SUMPROD(条件，值)和 SUM(条件*值)之间的区别
假设我有一个包含 2 列的 Excel 表格:单元格 A1 到 A10 中的日期和 B1 到 B10 中的值。我想对五月日期的所有值求和。我有3种可能性: {=SUM((MONTH(A1:A10)=
python - 将 Z 值(Z 值，标准分数)转换为 Python 中正态分布的 p 值
如何转换 Z-score来自 Z-distribution (standard normal distribution, Gaussian distribution)到 p-value ?我还没有找到
javascript( bool 值 ^ bool 值)
我正在重写一些 Javascript 代码以在 Excel VBA 中工作。由于在这个网站上搜索，我已经设法翻译了几乎所有的 Javascript 代码!但是，有些代码我无法准确理解它在做什么。这是一
php - 在php中的数组内添加新的键，值(值= 1)
我遇到过包含日期格式的时间戳日期的情况。然后我想构建一个图表，显示“点击”项目的数量“每天”， //array declaration $array1 = array("Date" => 0); $a
scala - Option(值)和Some(值)之间的差异
我是scala的新手! 我的问题是，是否有包含成员的案例类 myItem:Option[String] 当我构造类时，我需要将字符串内容包装在: Option("some string") 要么 So
php - 从表中选择 * 其中列 = 值 ^ column2 = 值
我正在用 PHP 创建一个登录系统。我需要用户使用他或她的用户名或电子邮件或电话号码登录然后使用密码。因为我知道在 Java 中我们会像 email==user^ username == user 这
c++ - WHERE 列 = 值，仅适用于 INTEGER 值
我在 C++ 项目上使用 sqlite，但是当我在具有文本值的列上使用 WHERE 时出现问题我创建了一个 sqlite 数据库: CREATE TABLE User( id INTEGER
c++ - 类类名(值)；和类类名=值；显式构造函数时的区别
当构造函数是显式时，它不用于隐式转换。在给定的代码片段中，构造函数被标记为 explicit。那为什么在 foo obj1(10.25); 情况下它可以工作，而在 foo obj2=10.25; 情况
c# - : if(! 值) 或 if(flag == 值) 哪个更清晰？
我知道这是一个主观问题，所以如果需要关闭它，我深表歉意，但我觉得它经常出现，让我想知道是否普遍偏爱一种形式而不是另一种形式。显然，最好的答案是“重构代码，这样你就不需要测试是否存在错误”，但有时没有
jquery - [属性~=值] 和 [属性*=值] 有什么区别？
这两个 jQuery 选择器有什么区别？以下是来自 w3schools.com 的定义: [attribute~=value] 选择器选择带有特定属性，其值包含特定字符串。 [attribute*=
CSS [属性|=值] 与 [属性*=值] 选择器
为什么我们需要CSS [attribute|=value] Selector根本当 CSS3 [attribute*=value] Selector基本上完成相同的事情，浏览器兼容性几乎相似？是否存在
java - 正则表达式仅验证 0 值。要验证的单个 0 值
我正在解决 regx 问题。我已经有一个像这样的 regx [0-9]*([.][0-9]{2})。这是 amont 格式验证。现在，通过此验证，我想包括不应提供 0 金额。比如 10 是有效的，但
java - 尽管代码删除了 "0"值，但为什么列表中仍保留 "0"值？
我正在研究计算机科学 A 考试的样题，但无法弄清楚为什么以下问题的正确答案是正确的。考虑以下方法。 public static void mystery(List nums) { for (
perl - 基本的 Perl 散列排序键，值，但也键 AND 值
好的，我正在编写一个 Perl 程序，它有一个我收集的值的哈希值(完全在一个完全独立的程序中)并提供给这个 Perl 脚本。这个散列是 (string,string) 的散列。我想通过 3 种方式对
mysql - 根据其他两列选择一列的 MAX 值，其中一列具有 MAX 值
我有一个表数据如下，来自不同的表。仅当第三列具有值“债务”并且第一列(日期)具有最大值时，我才想从第四列中获取最大值。最终值基于 MAX(DATE) 而不是 MAX(PRICE)。所以用简单的语言来说
php - 代码仅更新数据库中的 false 值，但不更新 true 值
我有一个奇怪的情况，只有错误状态保存到数据库中。当“状态”应该为 true 时，我的查询仍然执行 false。我有具有此功能的 Controller public function change_a
mysql SUM(值) 其中 SUM(值) > 2500
我有一个交易表(针对所需列进行了简化): id client_id value 1 1 200 2 2 150 3 1

行者123

个人简介

我是一名优秀的程序员,十分优秀！

作者热门文章

滴滴打车优惠券免费领取

全站热门文章

首页

博学

6Ren·AI

商城

java - JDBC - 双值未显示在 MySQL 数据库中